以下內容是我之前配置的集群同步方案，
腳本路徑
/usr/local/kafka/bin/kafka-mirror-maker.sh
consumer.properties
bootstrap.servers=10.255.30.152:9092
group.id=mirrorGroupTest
auto.offset.reset=earliest
partition.assignment.strategy=org.apache.kafka.clients.consumer.RoundRobinAssignor
producer.properties
bootstrap.servers=10.255.30.132:9092 compression.type=none retries=3
啟動腳本：start-mirror-maker.sh
nohup bin/kafka-mirror-maker.sh --consumer.config MirrorMaker/consumer.properties --producer.config MirrorMaker/producer.properties --whitelist ' test' &
如需要除錯，查看debug日志 可以修改
/usr/local/kafka/config/tools-log4j.properties
接下來進行測驗：
需要注意的問題：
consumer.properties （10.255.30.152:9092） 需要同步的訊息源集群
producer.properties （10.255.30.132:9092） 為訊息目標集群
結果：訊息寫入10.255.30.152:9092 集群， 此時訊息會被復制到目標集群10.255.30.132:9092，
惠惠街 每天千款優惠劵秒殺
轉載請註明出處，本文鏈接：https://www.uj5u.com/yidong/216996.html
標籤：其他