我正在使用apachecamel与kafka消息集成。我还使用javadsl来使用kafka端点的消息。
使用ApacheKafkaAPI的已知方法提交给定属性切换的使用者偏移量。
如果我在camel kafka组件中取消自动提交，那么我如何在apcahe camel中提交偏移量呢？
我正在使用below endpoint在apache camel中禁用自动提交
kafka.consumer.uri=kafka://{kafka.host}？zookeeperhost={{zookeeper.host}}&zookeeperport={{zookeeper.port}}&groupid={{kafka.consumergroupid}}&topic={{kafka.topic.transformer}&{kafka.uri.options}}kafka.uri.options=autocommitable=false
现在有没有办法手动提交消息偏移量？