E
spark-core
, kafka
и сейчас еще ищу откуда взять org/apache/kafka/common/protocol/SecurityProtocol
- не стартует kafkaTestUtils.setup()
. Возможно инфа про это есть где-то в предыдущих частях статей, если так то стоит дать ссылку в туда.Применяемый в примере кода
Utils.deleteRecursively
является приватным объектом из внутрянки спарка, то есть доставать этот метод надо тоже через хак, по аналогии с PublicKafkaTestUtils
И это пример всё еще не запустился…
Второй вариант это написать перед примером кода - это просто пример, который показывает базовый принцип но не запускается
Третий вариант, в конце статьи дать ссылку на репозиторий где будут микро-проекты с рабочими примерами - это в разы повысит полезность материала.