psringboot应用程序中的KafkaProducer事务

Question

我想在成功发送关于kafka主题的所有消息后执行一些代码。我读了很多文章。了解了我们可以使用事务发送消息。

kafkaTemplate.executeInTransaction(operations -> {
for (String s : request) {
kafkaTemplate.send(new ProducerRecord<>(topic,key,s));
}
return null;
});

我尝试过这种短代码，但不确定在成功执行此事务后如何执行某些代码。我也尝试过kafkaProducer启动交易，但这对我的案件也不起作用。如果有什么想法的话会很有帮助。

Answer 1

1. 消费者必须具有isolation.level=read_committed才能在提交记录之前查看记录。

2. 没有办法阻止消费者看到在交易之外发送的记录。