Работник Kafka Connect отсутствует классы AbstractConfig и AvroConverterConfig - PullRequest
Новая
       9

Работник Kafka Connect отсутствует классы AbstractConfig и AvroConverterConfig

0 голосов
/ 17 февраля 2020

Я пытаюсь использовать kafka connect JDB C разъем раковины с avro. Но когда я пытаюсь запустить соединитель, я получаю две следующие ошибки:

java .lang.NoClassDefFoundError: io / confluent / connect / avro / AvroConverterConfig

и

java .lang.NoClassDefFoundError: io / confluent / common / config / AbstractConfig.

Я немного, но запутался здесь, потому что мой путь к плагину /app/confluent-5.0.0/share/java

confluent-5.0.0 / share / java

И мы видим, что там находится банка, соответствующая отсутствующему классу.

Кто-нибудь имеет представление о том, что вызывает этот пропавший класс?

Большое спасибо!

1 Ответ

0 голосов
/ 17 февраля 2020

В основном я только что вытащил двоичные файлы для confluent-5.0.0 из confluent, у меня есть собственный скрипт, который получает переменную env и присваивает им рабочие переменные, например:

if ["$ 1" = 'bash']; затем exe c "$ @" else if [-z "$ KAFKA_CONNECT_BOOTSTRAP_SERVERS"]; затем экспортируйте KAFKA_CONNECT_BOOTSTRAP_SERVERS = "kafka: 9092" fi

if [-z "$ KAFKA_CONNECT_GROUP_ID"]; затем экспортируйте KAFKA_CONNECT_GROUP_ID = "connect-cluster" fi

и затем вызовите в конце:

exe c $ SCRIPTS / connect_distributed. sh /tmp/temp.properties

...