diff --git a/src/main/java/com/example/template/config/kafka/KafkaReceiverConfig.java b/src/main/java/com/example/template/config/kafka/KafkaReceiverConfig.java index 6b20678..b6969e5 100644 --- a/src/main/java/com/example/template/config/kafka/KafkaReceiverConfig.java +++ b/src/main/java/com/example/template/config/kafka/KafkaReceiverConfig.java @@ -28,7 +28,8 @@ public class KafkaReceiverConfig { props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers); props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class); props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class); - props.put(ConsumerConfig.GROUP_ID_CONFIG, "products"); + long seed = System.currentTimeMillis(); + props.put(ConsumerConfig.GROUP_ID_CONFIG, "products"+seed); props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true);