Я запускаю команду:
"JAVA_HOME=./jdk ./origin/bin/kafka-run-class.sh kafka.tools.MirrorMaker --whitelist ".*" --consumer.config config/consumer_mirror.properties --producer.config config/producer_mirror.properties"
, чтобы создать зеркало, однако копируется только имя темы, данные не копируются
содержимое файла свойств потребителяравно
zookeeper.connect=10.40.80.61:2181
# timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=1000000
#consumer group id
group.id=mirror-maker-group1
#consumer timeout
#consumer.timeout.ms=5000
mirror.topics.whitelist=*
client.id=mirror_maker_consumer1
содержимое файла свойств производителя равно
metadata.broker.list=localhost:9092
# name of the partitioner class for partitioning events; default partition spreads data randomly
#partitioner.class=
# specifies whether the messages are sent asynchronously (async) or synchronously (sync)
producer.type=async
# specify the compression codec for all data generated: none , gzip, snappy.
# the old config values work as well: 0, 1, 2 for none, gzip, snappy, respectivally
compression.codec=none
# message encoder
serializer.class=kafka.serializer.DefaultEncoder
client.id=mirror_maker_producer