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

Question

我能够使用apache kafka提交偏移类并能够使用ConsumerConnector进行提交.我查看了apache camel-kafka组件,其消费者选项为" autoCommitEnable ",与" auto.commit.enable "属性相同.现在是Camel Java DSL中的任何属性或方法,在消费消息之后我们可以手动提交偏移(通过URL中提供的方法或消费者选项) 或者 我们必须再次使用Kafka Consumer API来提交消费者偏移吗？

Answer 1

您可以使用 KafkaManualCommit 提交

请检查文档 https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/docs/kafka-component.adoc#using-manual-commit-with-kafka-consumer

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