This could be related to KAFKA-1890, which just got fixed in trunk. Could you try latest trunk?
Thanks, Jun On Fri, Jan 23, 2015 at 3:17 AM, tao xiao <xiaotao...@gmail.com> wrote: > Hi team, > > I got NPE when running the latest mirror maker that is in trunk > > [2015-01-23 18:55:20,229] INFO > [kafkatopic-1_LM-SHC-00950667-1422010513674-cb0bb562], exception during > rebalance (kafka.consumer.ZookeeperConsumerConnector) > > java.lang.NullPointerException > > at > > kafka.tools.MirrorMaker$InternalRebalanceListener.beforeReleasingPartitions(MirrorMaker.scala:631) > > at > > kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.kafka$consumer$ZookeeperConsumerConnector$ZKRebalancerListener$$rebalance(ZookeeperConsumerConnector.scala:674) > > at > > kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1$$anonfun$apply$mcV$sp$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:625) > > at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:141) > > at > > kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcV$sp(ZookeeperConsumerConnector.scala:616) > > at > > kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply(ZookeeperConsumerConnector.scala:616) > > at > > kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply(ZookeeperConsumerConnector.scala:616) > > at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) > > at > > kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:615) > > at > > kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:931) > > at > > kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.<init>(ZookeeperConsumerConnector.scala:965) > > at > > kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:163) > > at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:273) > > at kafka.tools.MirrorMaker.main(MirrorMaker.scala) > > > Here is the command I run > > > bin/kafka-run-class.sh kafka.tools.MirrorMaker --consumer.config > ~/Downloads/kafka/kafka_2.9.2-0.8.1.1/config/consumer.properties > --producer.config > ~/Downloads/kafka/kafka_2.9.2-0.8.1.1/config/producer.properties > --num.streams 2 --num.producers 2 --no.data.loss --whitelist ".*" > > -- > Regards, > Tao >
