We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ac49106 commit 06ec711Copy full SHA for 06ec711
1 file changed
apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/KafkaOutboxConsumer.java
@@ -12,6 +12,7 @@
12
import org.springframework.kafka.annotation.KafkaListener;
13
import org.springframework.kafka.support.Acknowledgment;
14
import org.springframework.stereotype.Component;
15
+import org.springframework.transaction.annotation.Transactional;
16
17
import java.util.List;
18
@@ -25,6 +26,7 @@ public class KafkaOutboxConsumer {
25
26
topics = {"product-viewed"},
27
containerFactory = KafkaConfig.BATCH_LISTENER
28
)
29
+ @Transactional
30
public void demoListener(
31
List<ConsumerRecord<String, String>> messages,
32
Acknowledgment acknowledgment
0 commit comments