You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

17 lines
482 B

2 years ago
#
#kafka的配置
#
# Kafka集群地址
bootstrap.servers="master:9092,slave1:9092,slave2:9092"
# ZooKeeper集群地址
zookeeper.connect="master:2181,slave1:2181,slave2:2181"
# Kafka Topic名称
input.topic="canal"
# 消费组ID
group.id="canal"
# 自动提交拉取到消费端的消息offset到kafka
enable.auto.commit="true"
# 自动提交offset到zookeeper的时间间隔单位毫秒
auto.commit.interval.ms="5000"
# 每次消费最新的数据
auto.offset.reset="latest"