Подтверждение клиента в Camel-Kafka - PullRequest
Новая
       32

Подтверждение клиента в Camel-Kafka

0 голосов
/ 21 апреля 2020

Я пользуюсь верблюжьей-кафкой версии 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. Ниже представлен URI-код kafka: 

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

1 Ответ

0 голосов
/ 21 апреля 2020

Вы можете использовать фиксацию вручную через 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

...