我有两个 Kafka 集群在两个不同 ec2 实例上的 docker 容器中运行,而我正在运行镜像制造商,我的主题正在被复制
源集群:10.0.0.2 目标集群:10.0.0.1
生产者.config
bootstrap.servers=10.0.0.2:9092
# specify the compression codec for all data generated: none, gzip, snappy, lz4
compression.type=none
acks=1
batch.size=100
client.id=mirror_maker_producer
retries=2147483647
max.in.flight.requests.per.connection=1
消费者.config
bootstrap.servers=10.0.0.1:9092
# consumer group id
#group.id=test-consumer-group
exclude.internal.topics=true
client.id=mirror_maker_consumer
group.id=mirror-maker
auto.offset.reset=earliest
partition.assignment.strategy=org.apache.kafka.clients.consumer.RoundRobinAssignor
我正在运行目标集群的以下命令
bin/kafka-run-class.sh kafka.tools.MirrorMaker --consumer.config config/consumer.properties --producer.config config/producer.properties --num.streams 3 --whitelist mirror_8
主题存在于源集群上,但未在目标集群上复制