2017-02-22 52 views
0

我試圖在兩個運行版本0.8.2.1的AWS Kafka/Zookeeper集羣之間鏡像Kafka數據。Kafka鏡像無法找到Set的集合(ArrayIndexOutOfBoundsException:11)

我可以從目標集羣試圖運行此命令但是當訪問源羣集飼養員卡夫卡的情況下,列出主題,等等:

/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) 

調試此錯誤的最佳方法是什麼?我已經在線閱讀了幾篇文章,但他們指出了從網絡連接到磁盤空間問題的一系列原因。 我很感謝你在這件事情上的幫助。

回答

0

顯然有卡夫卡嚴重的bug 0.8.2.1版本還沒有被2015年以來固定: https://issues.apache.org/jira/browse/KAFKA-2082 「失敗,原因是負責人的分區不是本地」

它看起來像有沒有辦法處理與此卡夫卡升級到最新版本的短暫。基於我在網上發現的其他帖子,它看起來像Kafka鏡像不適用於不同版本的卡夫卡之間,所以這是另一個需要考慮的事情。