我正在尝试使用下面的命令使用卡夫卡主题中的消息。但它不起作用。
bin/kafka-console-consumer.sh --bootstrap-server BROKER_URL --topic TOPIC_NAME --from-beginning
我的同事使用了下面的查询,它正在工作。
bin/kafka-console-consumer.sh --bootstrap-server BROKER_URL --topic TOPIC_NAME --offset 0 --partition 0