apache-camel – 目的和差异b / w Apache camel Kafka使用者URI选项consumerStreams vs consumersCount

Apache Camel Kafka Consumer提供名为“consumerStreams”和“consumersCount”的URI选项.

需要了解差异和使用方案以及它如何适应多分区Kafka主题消息消费

最佳答案 我查了一下Camel Kafka的源代码,看来这些参数加时有不同的用法.

consumerStreams用于旧版本的Camel-Kafka组件,例如2.13,你可以看到here

consumersCount用于Camel-Kafka组件的最新版本(参见here),它表示将被实例化的org.apache.kafka.clients.consumer.KafkaConsumer的数量,因此您应该将其用于多分区消耗

它似乎在骆驼2.16中一起使用

点赞