java - Camel kafka maxPollRecords配置是什么意思

Question

假设我们通过执行以下简单代码获得如下交换。 kafkaEndpoint 的 maxPollRecords 配置如何影响这一点。执行以下代码后，echange 将仅收到来自 kafka 的一条消息。 maxPollRecords 的默认值为 500。

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

当使用kafka库时，很明显，因为consumer.poll()将像下面一样返回

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

因此记录中只有 500 条记录。但是说到 Camel 卡夫卡这意味着什么？

Answer 1

选项 maxPollRecords 是相同的，它是 kafka 选项，它执行的操作可以在 Apache Camel 和 Kafka 的文档中找到。

另一方面，您使用的 API 不同，通过 Camel ConsumerTemplate 的第一个 API 用于单个交换(也称为消息)消费。因此您收到 1 条消息。

通常在 Camel 中设置一条路由，例如 Camel Kafka 示例 ( https://github.com/apache/camel/blob/master/examples/camel-example-kafka/README.adoc )，其中路由将根据 maxPollRecords 选项默认轮询最多 500 条消息，然后在 Camel 中路由这 500 条消息。