Kafka的最大民意调查记录在随后的民意调查中有所改变

fykwrbwg  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(215)

2个生产者正在生成与单个分区主题类似的消息。消息在大小(约700kb)和结构方面是相似的。每个生产者发送500条信息。
在第一生产者发送了所有消息之后,消费者可以在一次轮询()中接收所有500条消息。假设,在第二个生产者发送消息之后,消费者也应该在一次poll()中收到500条消息。但是,它在每个poll()中只读取100条消息。
为什么消费者对不同的生产者有不同的行为?
我的消费者配置了以下参数。

max.poll.records=500
fetch.max.bytes=500000000

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题