From 84af9642a851612e061100b6633b0fe547547a2f Mon Sep 17 00:00:00 2001 From: kimscott Date: Mon, 23 Sep 2019 15:12:10 +0900 Subject: [PATCH] =?UTF-8?q?groupid=20=EC=B6=A9=EB=8F=8C=20=EB=B0=A9?= =?UTF-8?q?=EC=A7=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/example/template/config/kafka/KafkaReceiverConfig.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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);