2个生产者正在生成与单个分区主题类似的消息。消息在大小(约700kb)和结构方面是相似的。每个生产者发送500条信息。
在第一生产者发送了所有消息之后,消费者可以在一次轮询()中接收所有500条消息。假设,在第二个生产者发送消息之后,消费者也应该在一次poll()中收到500条消息。但是,它在每个poll()中只读取100条消息。
为什么消费者对不同的生产者有不同的行为?
我的消费者配置了以下参数。
max.poll.records=500
fetch.max.bytes=500000000
2个生产者正在生成与单个分区主题类似的消息。消息在大小(约700kb)和结构方面是相似的。每个生产者发送500条信息。
在第一生产者发送了所有消息之后,消费者可以在一次轮询()中接收所有500条消息。假设,在第二个生产者发送消息之后,消费者也应该在一次poll()中收到500条消息。但是,它在每个poll()中只读取100条消息。
为什么消费者对不同的生产者有不同的行为?
我的消费者配置了以下参数。
max.poll.records=500
fetch.max.bytes=500000000
暂无答案!
目前还没有任何答案,快来回答吧!