0

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

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

4

0 回答 0