使用apache camel的camel-kafka组件手动提交消费者补偿

Question

我能够使用ApacheKafka提交偏移量类，并能够使用ConsumerConnector进行提交。我查看了apache camel kafka组件，该组件的使用者选项与“auto.commit.enable”属性相同。现在，Camel Java DSL中是否有任何属性或方法，在使用消息后，我们可以手动提交偏移量（通过URL中提供的方法或消费者选项），或者我们必须再次使用Kafka消费者API提交消费者偏移量？

Answer 1

您可以使用KafkaManualCommit提交

请检查文件https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/docs/kafka-component.adoc#using-与Kafka消费者手动提交

public void process(Exchange exchange) {
    KafkaManualCommit manual =
        exchange.getIn().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class);
    manual.commitSync();
}