卡夫卡镜子制造商0.10.2.0不工作

Question

我使用卡夫卡0.10.2.0和我试图使用卡夫卡镜子制造商选项。

consumer.properties：

bootstrap.servers=ip_source1:9092, ip_source2:9092 
group.id=mirror_maker_2 
partition.assignment.strategy=org.apache.kafka.clients.consumer.RoundRobinAssignor 

producer.properties：

bootstrap.servers=ip_dest1:9092, ip_dest2:9092 
auto.create.topics.enable=true 

消费者&生产者与版本卡夫卡0.10.1。

我用下面的命令运行kaffka镜制造商脚本：

opt/kafka/bin/kafka-run-class.sh kafka.tools.MirrorMaker --producer.config opt/kafka/config/producer.properties --consumer.config opt/kafka/config/consumer.properties --whitelist * --num.streams 10 

我发送邮件主题：“一”在ip_source1和卡夫卡控制台消费者我看到消息。

但在ip_dest1和ip_des2中，我看不到该消息。而且，当我观看主题“a”时，我没有在我的kafka-mirror-maker机器中看到它。

在调试模式中没有错误 - 只是："DEBUG Received successful Heartbeat response for group mirror_maker_2"

Answer 1

白名单是一个Java正则表达式。尝试“。*”包括引号而不是*。您也可以使用主题名称进行测试，以消除正则表达式问题。