X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;ds=inline;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FAddNumberMessage.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FAddNumberMessage.java;h=88b5d6f011de5d4d7db28bd7972b6912f256cfa3;hb=6369c42cebd818fda8c518813443eb907629ce41;hp=0000000000000000000000000000000000000000;hpb=da2a54acdaa2e7ad6e77e93f111cf27603617d23;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/AddNumberMessage.java b/src/main/java/de/juplo/kafka/AddNumberMessage.java
new file mode 100644
index 0000000..88b5d6f
--- /dev/null
+++ b/src/main/java/de/juplo/kafka/AddNumberMessage.java
@@ -0,0 +1,11 @@
+package de.juplo.kafka;
+
+import lombok.Value;
+
+
+@Value
+public class AddNumberMessage
+{
+  private final int number;
+  private final int next;
+}