【发布时间】:2017-07-12 22:10:16
【问题描述】:
我正在尝试在两个运行版本 0.8.2.1 的 AWS Kafka/Zookeeper 集群之间镜像 Kafka 数据。
我可以从目标集群 Kafka 实例、列表主题等访问源集群 Zookeeper。但是,当尝试运行此命令时:
/opt/kafka/bin/kafka-run-class.sh kafka.tools.MirrorMaker
--consumer.config /opt/kafka/config/mirror-consumer.properties
--num.streams 1
--producer.config /opt/kafka/config/mirror-producer.properties
--whitelist=".*"
我收到以下错误:
WARN Fetching topic metadata with correlation id 0 for topics [...] from broker [...] failed (kafka.client.ClientUtils$)
java.lang.ArrayIndexOutOfBoundsException: 11
at kafka.api.TopicMetadata$$anonfun$readFrom$1.apply$mcVI$sp(TopicMetadata.scala:38)
at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:78)
at kafka.api.TopicMetadata$.readFrom(TopicMetadata.scala:36)
调试此错误的最佳方法是什么?我在网上阅读了几篇文章,但它们指出了一系列原因,从网络连接到磁盘空间问题。 非常感谢您在这件事上的帮助。
【问题讨论】:
标签: amazon-web-services apache-kafka apache-zookeeper