Опция получения нераспознанного: --topic при выполнении ReadFromKafka.java

Я получаю сообщение об ошибке ниже при выполнении ReadFromKafka.java

Источник доступен на https://github.com/dataArtisans/kafka-example/blob/master/src/main/java/com/dataartisans/ReadFromKafka.java

Неизвестный параметр: --topic Ошибка: не удалось создать виртуальную машину Java. Ошибка. Произошло фатальное исключение. Программа будет закрыта.

Я привел следующие аргументы:

--topic test --bootstrap.servers localhost:9092 --zookeeper.connect localhost:2181 --group.id myGroup

Я выполнил шаги, данные http://data-artisans.com/kafka-flink-a-practical-how-to/

Заранее спасибо

~SC


apache-kafka apache-flink
person Soumyajit Chatterjee    schedule 07.04.2016    source источник

Ответы (3)


arrow_upward
0
arrow_downward

Как вы пытаетесь начать пример? Из IDE?

Если да, то уверены ли вы, что поместили аргументы в раздел «аргументы программы», а не в аргументы JVM?

person Robert Metzger    schedule 07.04.2016
comment
Большой. Можете ли вы отметить мой ответ как правильный? - person Robert Metzger; 08.04.2016

arrow_upward
0
arrow_downward

Проблема в том, чтобы вызвать вашу банку.

Попробуйте что-то вроде этого

java -jar myjar.jar "--topic test --bootstrap.servers localhost: 9092 --zookeeper.connect localhost: 2181 --group.id myGroup"

person Sand    schedule 07.04.2016

arrow_upward
0
arrow_downward

Это происходило для меня, потому что не было действительных файлов jar, содержащих код kafka. Поскольку допустимые jar-файлы не найдены, переменная CLASS_PATH пуста в bin/kafka-run-class.sh. Этот сценарий оболочки, вероятно, должен проверить это условие и вернуть более точную ошибку, вместо этого он просто оставляет недопустимый флаг -cp в команде java, которую он собирает. Это вызывает сообщение об ошибке, которое вы (мы) видим, где выдает информацию об использовании java (потому что -cp без каких-либо последующих действий является недопустимым).

Решением для меня было собрать исходный код kafka с использованием gradlew jar.

Корень этой проблемы в том, что в документации предполагается, что вы будете запускаться из реальной установки kafka, а не из каталога src.

person payneio    schedule 17.06.2017