kafkaProducer在psringboot应用程序中的交易

Question

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

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

我尝试了这么短的代码，但不确定如何在这个事务成功执行后执行一些代码。我也尝试过Kafka普勒，开始交易，但这对我的案子也不起作用。如果有什么想法的话会很有帮助。

Answer 1

>

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

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