步骤 3 修改kafka的配置文件:
vi ~/rel/antcdc/config/server.properties按照实际情况进行配置:
broker.id=0 【每台主机使用不同的id】
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://10.21.10.146:9092
log.dirs=kafka-logs【根据要求配置】
num.partitions=6
zookeeper.connect=10.21.10.146:2181,10.21.10.148:2181,10.21.10.149:2181
#对应3.2.2 步骤8启动的所有Zookeeper服务节点
offsets.topic.replication.factor=3
replication.factor=3
transaction.state.log.replication.factor=3
transaction.state.log.min.isr=3步骤 4 修改kafka connect的配置文件
vi ~/rel/antcdc/config/connect-distributed.properties按照实际情况进行配置:
bootstrap.servers=10.21.10.146:9092,10.21.10.148:9092,10.21.10.149:9092
#对应3.2.2 步骤9启动的所有kafka服务节点
listeners=HTTP://10.21.10.146:8083
offset.storage.replication.factor=3
config.storage.replication.factor=3
status.storage.replication.factor=3
rest.extension.classes=com.ai.dbsync.metric.ext.DbSyncMetricRestExtension
plugin.path=dbsync-lib关于AntDB数据库
电信级核心交易数据库AntDB 数据库始于 2008年,在运营商的核心系统上,为全国 24个省份的 10亿多用户提供在线服务;具备高性能、弹性扩展、高可靠等产品特性,每秒可处理十多万笔核心交易,并保障系统平稳运行超 10年零故障。 AntDB 广泛应用于通信、金融、交通、能源、物联网等多个行业,在 200多个项目上成功落地。
「喜欢这篇文章,您的关注和赞赏是给作者最好的鼓励」
关注作者
【版权声明】本文为墨天轮用户原创内容,转载时必须标注文章的来源(墨天轮),文章链接,文章作者等基本信息,否则作者和墨天轮有权追究责任。如果您发现墨天轮中有涉嫌抄袭或者侵权的内容,欢迎发送邮件至:contact@modb.pro进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。




