Camel kafka maxPollRecords 配置是什么意思

Question

可以说，我们可以通过执行简单代码来获得以下内容。Kafkaendpoint的MaxPolleRecords配置如何影响这一点。执行以下代码后，Echange将只有Kafka的一条消息。默认值是MaxPolleRecords为500。

Exchange exchange = kafkaConsumer.receive(kafkaEndpoint, 100);//ConsumerTemplate kafkaConsumer;

使用kafka库时，很明显，因为cumput.poll((将返回如下

ConsumerRecords<String, String> records = consumer.poll(100);

因此，记录中只有500个记录。但是，当涉及到骆驼卡夫卡时，这是什么意思？

Answer 1

选项 maxPollRecords是相同的，它是kafka选项，并且可以在Apache Camel和Kafka上可以在文档上找到的内容。

另一方面，您使用的API是不同的，第一个通过骆驼消费板的API用于消耗 single Exchange(又称消息(。因此，您会收到1条消息。

通常在骆驼中您设置了一条路线，例如骆驼kafka示例(https://github.com/apache/camel/camel/blob/master/master/examples/camel-example-kafka/readme.adoc(默认情况下，根据maxPollRecords选项进行轮询最大500条消息，然后在骆驼中路由这500条消息。