文档地址
kafkasink/kafkawriter参数说明:
consumerSettings
描述:kafka连接配置,支持所有kafka.consumer.ConsumerConfig.ConsumerConfig中定义的配置
必选:是
字段类型:Map
默认值:无
如:
{
"consumerSettings":{
"bootstrap.servers":"host1:9092,host2:9092,host3:9092"
}
}
此参数是kafkasource/kafkareader的配置参数,kafkasink/kafkawriter应该是如下参数,文档中缺少此参数的说明:
"producerSettings": {
"auto.commit.enable": "false",
"bootstrap.servers": "localhost:9092"
}