这家伙太懒,什么都没留下
auto.offset.reset 如果KafkaConsumer没有初始化的offset的话,就会采用这个策略,默认是latest,这样的话就会忽略第一条KafkaProducer生产的消息。
latest
你把auto.offset.reset改成latest,或许能解决你的问题
auto.offset.reset