X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FEndlessProducer.java;h=6b429548c42b23e5c389ac34c7fe7b673a027fee;hb=59e6285162b2b441f68c25ba4c969802faf44a2d;hp=43b0e41e7625364083aa1ae6157adb34799dda74;hpb=6db60eede6c6a14a20fb88cdcd0e0be0e959d31b;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/EndlessProducer.java b/src/main/java/de/juplo/kafka/EndlessProducer.java
index 43b0e41..6b42954 100644
--- a/src/main/java/de/juplo/kafka/EndlessProducer.java
+++ b/src/main/java/de/juplo/kafka/EndlessProducer.java
@@ -45,6 +45,7 @@ public class EndlessProducer implements Runnable
     props.put("bootstrap.servers", bootstrapServer);
     props.put("client.id", clientId);
     props.put("acks", acks);
+    props.put("partitioner.class", "org.apache.kafka.clients.producer.RoundRobinPartitioner");
     props.put("key.serializer", StringSerializer.class.getName());
     props.put("value.serializer", StringSerializer.class.getName());