我正在使用.poll方法在我的应用程序中，我的延迟中有很多消息，但是在.poll调用时，为什么我们只返回很少的消息？。我只有一个主题和5个分区，到目前为止，所有的数据只进入一个分区。SpringKafka1.3.9发布Kafka->1.0
mzillmmw1#
您可以通过增加 max.poll.records 默认值为500。使用此配置可限制要轮询的单个调用返回的总记录数。所有的数据只进入一个分区这取决于你的信息。如果您没有提供任何密钥，您的消息将随机分布在各个分区中。在您提供密钥的情况下，密钥将被散列，具有相同密钥的消息将进入相同的分区。https://kafka.apache.org/documentation/#consumerconfigs
max.poll.records
1条答案
按热度按时间mzillmmw1#
您可以通过增加
max.poll.records默认值为500。使用此配置可限制要轮询的单个调用返回的总记录数。所有的数据只进入一个分区
这取决于你的信息。
如果您没有提供任何密钥，您的消息将随机分布在各个分区中。
在您提供密钥的情况下，密钥将被散列，具有相同密钥的消息将进入相同的分区。
https://kafka.apache.org/documentation/#consumerconfigs