我们有一个应用程序,它使用来自Kafka主题(3个分区)的消息,并丰富数据并将记录保存在DB ( Spring JPA)中,然后将消息发布到另一个kafka主题(在同一代理上),所有这些都是通过使用Camel我们希望为kafka消费者-生产者组合实现“恰好一次”语义。end();
但是当存在异常处理场景时,我们无法让kafka生产者提交消息。我遗漏了什么,正确的方法是<em
我对kafka很陌生,我使用Kafka生产者Java。面对这个问题,卡夫卡,Kafka: Invalid transition attempted from state COMMITTING_TRANSACTION to state ABORTING_TRANSACTION人们已经写到,只有在没有交易的情况下,才应该调用producer.abortTransaction() .知道如何检查飞行中是否有交易吗?以及如何清除/阻止它们?= null){
logger.info(&q