MirrorMaker 1 은 Kafka 4.0 에서 제거됐다.
mirror-maker.sh와 관련 코드가 빠졌다[1].
3.x 이하에서만 쓸 수 있다. 현행 버전에서는 MM2 를 쓴다.
# list of brokers used for bootstrapping knowledge about the rest of the cluster
# format: host1:port1,host2:port2 ...
#bootstrap.servers=localhost:9092
bootstrap.servers=HOST_01:9092, HOST_02:9092, HOST_03:9092, ...
# consumer group id
group.id=SIEL_MIRROR
# What to do when there is no initial offset in Kafka or if the current
# offset does not exist any more on the server: latest, earliest, none
#auto.offset.reset=
# format: host1:port1,host2:port2 ...
#bootstrap.servers=localhost:9092
bootstrap.servers=HOST_01:9092, HOST_02:9092, HOST_03:9092, ...
# specify the compression codec for all data generated: none, gzip, snappy, lz4, zstd
compression.type=none
# name of the partitioner class for partitioning events; default partition spreads data randomly
#partitioner.class=
# the maximum amount of time the client will wait for the response of a request
#request.timeout.ms=
# how long `KafkaProducer.send` and `KafkaProducer.partitionsFor` will block for
#max.block.ms=
# the producer will wait for up to the given delay to allow other records to be sent so that the sends can be batched together
#linger.ms=
# the maximum size of a request in bytes
#max.request.size=
# the default batch size in bytes when batching multiple records sent to a partition
#batch.size=
# the total bytes of memory the producer can use to buffer records waiting to be sent to the server
#buffer.memory=
KAFKA_HOME=/home/manager/kafka
nohup $KAFKA_HOME/bin/kafka-mirror-maker.sh --consumer.config $KAFKA_HOME/conf/consumer.properties --producer.config $KAFKA_HOME/conf/producer.properties -num.streams 2 --whitelist="TOPIC_NAME.*" 2>&1> /dev/null &
KIP-720: Deprecate MirrorMaker v1 — 2026-09-16 확인. 4.0 에서 제거됐다. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=177046121 ↩︎