Version des Rest-Producers, der direkt Requests für den Sumup-Adder sendet

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

diff --git a/src/main/java/de/juplo/kafka/ProduceSuccess.java b/src/main/java/de/juplo/kafka/ProduceSuccess.java
index 9c79e8b..8afe795 100644 (file)
--- a/src/main/java/de/juplo/kafka/ProduceSuccess.java
+++ b/src/main/java/de/juplo/kafka/ProduceSuccess.java
@@ -7,6 +7,6 @@ import lombok.Value;
 @Value
 public class ProduceSuccess implements ProduceResult
 {
-  Integer partition;
-  Long offset;
+  Integer[] partition;
+  Long[] offset;
 }