我正在使用骆驼卡夫卡版本2.14.3
。以下是卡夫卡 URI:
<from uri="kafka:{brokerlist}?topic={topic-name}&zookeeperHost={zookeeperHost}&zookeeperPort={zookeeperPort}&groupId={groupId-name}&consumerStreams=2" />
请注意,我consumerStream=2
在 URI 选项中使用过。但是当我topic-name
一次向主题发布多条消息(全部到同一个分区)时,kafka 消费者会按顺序接收这些消息。如何并行接收这些消息?
我正在寻找如下解决方案:
<from uri="ibm_bean_name:queue_name?concurrentConsumers=2" />
是我用来从 ibm MQ 并发读取的内容