骆驼卡夫卡中的客户确认

Question

我正在使用 camel-kafka 版本 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集群端配置一些东西？

我正在使用 camel-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" />

Answer 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

骆驼卡夫卡中的客户确认

Client Acknowledge in camel-kafka

java

apache-camel

apache-kafka

ibm-mq