mindol1004/ddd-products
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

groupid 충돌 방지

Browse Source
This commit is contained in:
kimscott
2019-09-23 15:12:10 +09:00
parent b33e5ed41a
commit 84af9642a8
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/example/template/config/kafka/KafkaReceiverConfig.java
View File

@@ -28,7 +28,8 @@ public class KafkaReceiverConfig {
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers); props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class); props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
props.put(ConsumerConfig.VALUE_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.AUTO_OFFSET_RESET_CONFIG, "earliest");
props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true); props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true);