WIP

[demos/kafka/training] / src / main / java / de / juplo / kafka / SimpleProducer.java

diff --git a/src/main/java/de/juplo/kafka/SimpleProducer.java b/src/main/java/de/juplo/kafka/SimpleProducer.java
index b9e8152..3cf1128 100644 (file)
--- a/src/main/java/de/juplo/kafka/SimpleProducer.java
+++ b/src/main/java/de/juplo/kafka/SimpleProducer.java
@@ -58,6 +58,16 @@ public class SimpleProducer
     }
   }
 
+  void begin()
+  {
+    producer.beginTransaction();
+  }
+
+  void commit()
+  {
+    producer.commitTransaction();
+  }
+
   CompletableFuture<Long> send(String key, String value)
   {
     final CompletableFuture<Long> result = new CompletableFuture<>();