Вызывается: java .lang.ClassNotFoundException: org. apache .flink.streaming.connectors.kafka.FlinkKafkaConsumer

Question

У меня есть работа kafkaflink, которая работает в intellij, на упаковке с sbt я получаю следующее сообщение

Caused by: java.lang.ClassNotFoundException: 
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer

Спасибо, что взглянули на это

Answer 1

У вас наверняка есть зависимость Кафки как provided, или вы не создаете толстую банку.

Вам нужно использовать плагин в зависимости от инструмента сборки, который вы используете для sbt, это может быть sbt assembly, для maven это может быть maven-shade-plugin. И тогда Вам нужно иметь flink-kafka-connector в области компиляции.