java - Camel 卡夫卡中的客户端确认

Question

我使用的是camel-kafka版本2.14.3。我在从 ibm MQ 读取数据时通过创建 bean 来使用客户端确认，如下所示

<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