mindol1004/ddd-orders
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 4d0381b444
commit 716b01016b
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.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
props.put(ConsumerConfig.GROUP_ID_CONFIG, "orders");
long seed = System.currentTimeMillis();
props.put(ConsumerConfig.GROUP_ID_CONFIG, "orders"+seed);
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true);