X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FEndlessProducer.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FEndlessProducer.java;h=fcf42de3eebc8bf22c3dd1f3eb9cc43ecb30a32f;hb=refs%2Fheads%2Fround-robin;hp=8b3743d89fbc196861ee9edf3144540528d5351a;hpb=d4f93e07dfb4236423cde84f1a67b41fdc46c1f7;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 8b3743d..fcf42de 100644
--- a/src/main/java/de/juplo/kafka/EndlessProducer.java
+++ b/src/main/java/de/juplo/kafka/EndlessProducer.java
@@ -42,6 +42,7 @@ public class EndlessProducer implements Runnable
     props.put("client.id", clientId);
     props.put("acks", acks);
     props.put("metadata.max.age.ms", "1000");
+    props.put("partitioner.class", "org.apache.kafka.clients.producer.RoundRobinPartitioner");
     props.put("key.serializer", StringSerializer.class.getName());
     props.put("value.serializer", StringSerializer.class.getName());