【发布时间】:2023-02-17 13:51:58
【问题描述】:
如果您对此有解释,请分享详细信息。
当我尝试使用带有主题名称的 kafka-console-consumer 使用消息时,未使用数据。
bin]# ./kafka-console-consumer --bootstrap-server localhost:9092 --topic test1
但是,当我提到分区号时,消息就会被消耗掉。
bin]# ./kafka-console-consumer --bootstrap-server localhost:9092 --topic test1 --partition 0
test1
test2
test3
【问题讨论】:
-
您使用的是哪个 Kafka 版本?
标签: apache-kafka kafka-consumer-api