improve distribution of partitions across replicas

vostok · Oct 26, 2022 · ca7817a · ca7817a
1 parent a0e0b35
commit ca7817a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hercules-sink/src/main/java/ru/kontur/vostok/hercules/sink/Sink.java b/hercules-sink/src/main/java/ru/kontur/vostok/hercules/sink/Sink.java
@@ -100,7 +100,7 @@ public Sink(
 
         Properties consumerProperties = PropertiesUtil.ofScope(properties, Scopes.CONSUMER);
         consumerProperties.put(ConsumerConfig.GROUP_ID_CONFIG, consumerGroupId);
-        String consumerId = Application.context().getInstanceId() + "-" + CONSUMER_CLIENT_ID_SEQUENCE.getAndIncrement();
+        String consumerId = CONSUMER_CLIENT_ID_SEQUENCE.getAndIncrement() + "-" + Application.context().getInstanceId();
         consumerProperties.put(ConsumerConfig.CLIENT_ID_CONFIG, consumerId);
         consumerProperties.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, false);
         consumerProperties.putIfAbsent(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, batchSize);