X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FProduceSuccess.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FProduceSuccess.java;h=8afe7950154efcaeeca578a924f9bd0f42297a32;hb=6369c42cebd818fda8c518813443eb907629ce41;hp=9c79e8b4ac00125bab33bf5636d653bc5fa9017c;hpb=da2a54acdaa2e7ad6e77e93f111cf27603617d23;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/ProduceSuccess.java b/src/main/java/de/juplo/kafka/ProduceSuccess.java
index 9c79e8b..8afe795 100644
--- 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;
 }