Допомога у програмуванні, відповіді на питання / Java / kafka-connect error: не вдається знайти або завантажити основний клас - java, apache-kafka, kafka-споживач-api, kafka-produce-api

Кафика-підключення помилка: не вдається знайти або завантажити основний клас - java, apache-kafka, kafka-consumer-api, kafka-prod-api

Я стежу за офіційні документи для впровадження в kakf-connect читати дані з файлу.

У мене кафка працює ідеально. Виробник та споживач, що надсилає та отримує повідомлення.

Однак, коли я запускаю таку команду:

sudo ./bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties

Я отримую таку помилку:

Помилка: не вдалося знайти або завантажити основний клас org.apache.kafka.connect.cli.ConnectStandalone

Я перехрестив перевірку і маю файл ConnectStandalone тут connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.

Мій connect-file-source.properties полягає в наступному:

name=local-file-source
connector.class=org.apache.kafka.connect.file.FileStreamSourceConnector
tasks.max=1
file=test.txt
topic=spark-kafka

Щось бракує? Що мені робити, щоб позбутися цієї помилки?

Відповіді:

0 для відповіді № 1

Отже, будучи досить невідомим Java, я думаю, що проблема полягає в тому, що kafka-connect не входить до складу тарболів, які надає kafka.

Я замість цього перейшов на використання платформи, що зливається, і підключення працює чудово за допомогою тарболу: