我有两个kafka集群运行在docker容器中的两个不同ec2示例上,当我运行mirror maker时,我的主题被复制了
源群集:10.0.0.2目标群集:10.0.0.1
生产者配置
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
消费者配置
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
主题在源群集上存在,但在目标群集上不复制
暂无答案!
目前还没有任何答案,快来回答吧!