11.2. 为高卷消息配置 MirrorMaker 2
MirrorMaker 2 从源集群获取数据,并将其传递给 Kafka Connect 运行时制作者,以便将其复制到目标集群。
以下示例显示了 MirrorMaker 2 的配置。配置与从源获取消息的消费者相关,以及向目标 Kafka 集群发送消息的制作者。
用于处理大量消息的 MirrorMaker 2 配置示例
clusters=cluster-1,cluster-2
# ...
cluster-2.producer.batch.size=327680
cluster-2.producer.linger.ms=100
cluster-1.consumer.fetch.max.bytes=52428800
cluster-1.consumer.max.partition.fetch.bytes=1048576
cluster-1.consumer.max.poll.records=500
# ...
tasks.max = 2