对呀,你都知道是定义消费者的位置,那你永远都从最早的开始。
另外,你有什么特殊需求,要指定消费某个分区吗?
你就按照上面的解决方式,不要指定分区了。
2.4.1 版本的PartitionOffset是需要这个initialOffset参数的
你去掉initialOffset = "0"
,在给消费者换个名字:
spring.kafka.consumer.group-id=consumer
然后你继续生产,看看是否消费的到。
用命令工具,查看你这个消费者的具体情况:
## 显示某个消费组的消费详情(仅支持offset存储在zookeeper上的)
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group test
## 显示某个消费组的消费详情(0.9版本 - 0.10.1.0 之前)
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group test-consumer-group
## 显示某个消费组的消费详情(0.10.1.0版本+)
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
命令来自:kafka命令大全