From 5be01a7ce4a1362684ecf22d82ecf8800d5d0a34 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Tue, 2 Aug 2022 21:00:36 +0200 Subject: [PATCH] =?utf8?q?F=C3=BCr=20eine=20=C3=9Cbersichtliche=20=C3=9Cbe?= =?utf8?q?rgabe=20sollte=20CooperativeStickyAssignor=20aktiv=20sein?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit * Per Default ist immer noch der RangeAssignor vorgegeben, so dass die Partitionen bei jedem Rebalance komplett neu zugeordnet werden. * Um bei der Betrachtung der Effekte von Sauberem Stop vs. Kill vs. Freeze den Überblick behalten zu können, wurde der CooperativeStickyAssignor aktiviert. --- src/main/java/de/juplo/kafka/SimpleConsumer.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java index 4e2ca8c..03a9e6a 100644 --- a/src/main/java/de/juplo/kafka/SimpleConsumer.java +++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java @@ -28,6 +28,7 @@ public class SimpleConsumer props.put("bootstrap.servers", broker); props.put("group.id", groupId); // ID für die Offset-Commits props.put("client.id", clientId); // Nur zur Wiedererkennung + props.put("partition.assignment.strategy", "org.apache.kafka.clients.consumer.CooperativeStickyAssignor"); props.put("key.deserializer", StringDeserializer.class.getName()); props.put("value.deserializer", StringDeserializer.class.getName()); -- 2.20.1