kafka使用者指令行工具无法正常运作

问题描述

我正在使用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

apache-kafka kafka-consumer-api