未验证 提交 c56099fe 编写于 作者: A ai x 3 提交者: GitHub

Update KafkaFetcherHandlerRegister.java (#5564)

上级 1a27452f
......@@ -62,7 +62,8 @@ public class KafkaFetcherHandlerRegister implements Runnable {
public KafkaFetcherHandlerRegister(KafkaFetcherConfig config) throws ModuleStartException {
this.config = config;
Properties properties = new Properties(config.getKafkaConsumerConfig());
Properties properties = new Properties();
properties.putAll(config.getKafkaConsumerConfig());
properties.setProperty(ConsumerConfig.GROUP_ID_CONFIG, config.getGroupId());
properties.setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, config.getBootstrapServers());
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册