|
@ -47,7 +47,7 @@ public class KafkaConsumerConfig {
|
|
|
@Bean
|
|
|
public Map<String, Object> consumerConfigs() {
|
|
|
Map<String, Object> props = new HashMap<>();
|
|
|
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "master:9092");
|
|
|
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBrokerAddress);
|
|
|
props.put(ConsumerConfig.GROUP_ID_CONFIG, GROUP_ID);
|
|
|
props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true);
|
|
|
props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, 100);
|