kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tao xiao <xiaotao...@gmail.com>
Subject Got NPE when running the latest mirror maker that is in trunk
Date Fri, 23 Jan 2015 11:17:39 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message