我运行命令: "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
暂无答案!
目前还没有任何答案,快来回答吧!