循环poll(10000),手动commit,topic每天00点会生产30条数据,但是消费的时候消费不全,poll没有阻塞,也没有报错,但是poll的数据是空的,查看group情况,lag还有数据是什么情况
我的消费者配置:
bootstrap.servers = [node1:9092, node2:9092, node3:9092]
fetch.max.wait.ms = 3000
fetch.min.bytes = 1024*1024
group.id = console-consumer-92931
key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
max.poll.records = 1000
enable.auto.commit=false
value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer