X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FEndlessProducer.java;h=fcf42de3eebc8bf22c3dd1f3eb9cc43ecb30a32f;hb=refs%2Fheads%2Fround-robin;hp=7a5b324e144fddbaef84c036640e62448c6f7a4f;hpb=7d308db47ff0917ba100d6ab8a3fbf05e85bcdb9;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 7a5b324..fcf42de 100644
--- a/src/main/java/de/juplo/kafka/EndlessProducer.java
+++ b/src/main/java/de/juplo/kafka/EndlessProducer.java
@@ -41,6 +41,8 @@ public class EndlessProducer implements Runnable
     props.put("bootstrap.servers", bootstrapServer);
     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());