春季kafka与春季JPA

发布于 2025-02-09 23:51:43 字数 557 浏览 4 评论 0原文

我有两个微型服务A和B。

一项服务正在向Kafka主题“ A-Topic”发送消息。 B服务正在消耗消息。

在B服务中，Kafka侦听器将执行以下步骤，

             1. Persist the data in the database     (repo.save(entity))
             2. Publish the response message to "B-Topic".   (kafkatemplte.send("B-Topic",message))

我正在使用Spring @Transactional注释在两个服务中的服务级别。

在成功情况下，数据正在持续存在，并且成功消息仅发布给该主题一次

，因为

在失败方案中，由于完整性约束违规问题，数据库保存失败了。在这种情况下，失败消息将连续发布10次。

如果我从服务类中删除交易注释，则在失败方案中仅发布一次消息。

我不明白，交易注释是如何导致向Kafka发布10次消息的消息。

请让我知道您的意见。

提前致谢。

原文

I have two micro services A and B.

A service is sending message to Kafka topic "A-Topic". B service is consuming the message.

In the B service, kafka listener will do the below steps

             1. Persist the data in the database     (repo.save(entity))
             2. Publish the response message to "B-Topic".   (kafkatemplte.send("B-Topic",message))

I am using the Spring @Transactional annotation at the service level in both services.

In the success scenario, data is getting persisted and success message is published to the topic only once

where as

in the Failure scenario, database save was failed due to integrity constraint violation issue. In this case, failure message is published to the Kafka 10 times continuously.

If I remove Transactional annotation from the service class then the message is published only once in failure scenario also.

I don't understand, how come transactional annotation is causing the message to be published 10 times to kafka.

Please let me know your inputs.

Thanks in advance.

分享到QQ

分享到微博