Получение Непризнанных опций: --topic при выполнении ReadFromKafka.java

Question

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

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

Unrecognized option: --topic Error: Could not create the Java Virtual Machine. Error: A fatal exception has occurred. Program will exit.

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

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

Я следовал за стадиями, указанными http://data-artisans.com/kafka-flink-a-practical-how-to/

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

~ SC

Answer 1

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

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

Answer 2

Проблема с вызовом вашей банки.

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

Java -jar myJar.jar "--topic тест --bootstrap.servers LOCALHOST: 9092 --zookeeper.connect LOCALHOST: 2181 --group.id MyGroup"

Answer 3

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

Решение для меня состояло в том, чтобы построить источник кафки, используя gradlew jar.

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