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

Question

我使用的是 kafka 0.10.2.0，我正在尝试使用 kafka mirror maker 选项。

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

消费者和生产者使用的是 kafka 0.10.1 版本。

我通过以下命令运行 kaffka mirror maker 脚本：

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 中的 topic: "a" 发送消息，并使用 kafka-console-consumer 我看到了消息。

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

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

Answer 1

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