Kafka镜像制作不复制主题

yruzcnhs  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(304)

我有两个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

主题在源群集上存在,但在目标群集上不复制

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题