骆驼卡夫卡中的客户确认答案

【问题标题】：Client Acknowledge in camel-kafka骆驼卡夫卡中的客户确认
【发布时间】：2020-04-21 10:27:28
【问题描述】：

我正在使用骆驼卡夫卡版本 2.14.3 。我通过如下创建 bean 从 ibm MQ 读取时使用了客户端确认

<bean id="ibmMQwithClientAck" class="org.apache.camel.component.jms.JmsComponent">
    <property name="configuration">
        <bean class="org.apache.camel.component.jms.JmsConfiguration">
            <property name="acknowledgementModeName"
                value="CLIENT_ACKNOWLEDGE" />
            <property name="connectionFactory">
                <bean class="com.ibm.mq.jms.MQConnectionFactory">
                    <property name="transportType" value="<transportType>" />
                    <property name="hostName" value="<hostName>" />
                    <property name="port" value="<port>" />
                    <property name="channel" value="<channel>" />
                    <property name="queueManager" value="<queueManager>" />
                </bean>
            </property>
        </bean>
    </property>
</bean>

我正在camel-kafka 中寻找客户提交。这可以从消费者本身完成，还是需要在 kafka 集群端进行配置？

我正在使用骆驼卡夫卡版本 2.14.3 。下面是kafka URI：

<from uri="kafka:{brokerlist}?topic={topic-name}&amp;zookeeperHost={zookeeperHost}&amp;zookeeperPort={zookeeperPort}&amp;groupId={groupId-name}&amp;consumerStreams=2" />

【问题讨论】：

标签： java apache-kafka apache-camel ibm-mq

【解决方案1】：

您可以通过allowManualCommit=true 使用手动提交，请参阅文档：https://camel.apache.org/components/2.x/kafka-component.html

在专区：https://camel.apache.org/components/2.x/kafka-component.html#_using_manual_commit_with_kafka_consumer

【讨论】：

感谢您的回答。手动提交似乎仅在 2.21 骆驼版之后可用。我使用的是 2.14.3 版本。
Camel 2.14.x 从 2015 年开始相当旧。我建议如果可能的话考虑使用更新的 Camel 版本，当然是为了新的开发。