Блог

Я использую средство командной строки Kafka для использования данных из раздела Kafka, но это работает не так, как ожидалось. Я использую следующую команду :

 kafka-console-consumer.sh --bootstrap-server totkafka-console-consumer.sh --bootstrap-server localhost1:9092,localhost2:9092, localhost3:9092 --topic topic-name
  

и я получаю следующий стек ошибок:

 Exception in thread "main" joptsimple.MultipleArgumentsForOptionException: Found multiple arguments for option bootstrap-server, but you asked for only one
    at joptsimple.OptionSet.valueOf(OptionSet.java:179)
    at kafka.tools.ConsoleConsumer$ConsumerConfig.<init>(ConsoleConsumer.scala:301)
    at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:52)
    at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
  

Не могли бы вы, пожалуйста, помочь мне с этим?

С наилучшими пожеланиями

Ошибка синтаксиса в вашей команде, попробуйте ниже:

 kafka-console-consumer.sh --bootstrap-server localhost1:9092,localhost2:9092,localhost3:9092 --topic topic-name