Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - simple producer (kafka 0.7.2) exception


Copy link to this message
-
simple producer (kafka 0.7.2) exception
Oleg Ruchovets 2013-04-07, 10:15
try to execute kafka 0.7.2 and got such exception:
log4j:WARN No appenders could be found for logger
(org.I0Itec.zkclient.ZkConnection).
log4j:WARN Please initialize the log4j system properly.
Exception in thread "main" java.lang.NumberFormatException: null
 at java.lang.Integer.parseInt(Integer.java:417)
 at java.lang.Integer.parseInt(Integer.java:499)
 at scala.collection.immutable.StringLike$class.toInt(StringLike.scala:208)
 at scala.collection.immutable.StringOps.toInt(StringOps.scala:31)
 at
kafka.producer.ZKBrokerPartitionInfo$$anonfun$kafka$producer$ZKBrokerPartitionInfo$$getZKTopicPartitionInfo$1$$anonfun$5.apply(ZKBrokerPartitionInfo.scala:167)
 at
kafka.producer.ZKBrokerPartitionInfo$$anonfun$kafka$producer$ZKBrokerPartitionInfo$$getZKTopicPartitionInfo$1$$anonfun$5.apply(ZKBrokerPartitionInfo.scala:167)
 at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
 at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
 at scala.collection.Iterator$class.foreach(Iterator.scala:631)
 at
scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549)
 at scala.collection.IterableLike$class.foreach(IterableLike.scala:79)
 at
scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596)
 at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
 at
scala.collection.JavaConversions$JListWrapper.map(JavaConversions.scala:596)
 at
kafka.producer.ZKBrokerPartitionInfo$$anonfun$kafka$producer$ZKBrokerPartitionInfo$$getZKTopicPartitionInfo$1.apply(ZKBrokerPartitionInfo.scala:167)
 at
kafka.producer.ZKBrokerPartitionInfo$$anonfun$kafka$producer$ZKBrokerPartitionInfo$$getZKTopicPartitionInfo$1.apply(ZKBrokerPartitionInfo.scala:163)
 at scala.collection.Iterator$class.foreach(Iterator.scala:631)
 at
scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549)
 at scala.collection.IterableLike$class.foreach(IterableLike.scala:79)
 at
scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:596)
 at
kafka.producer.ZKBrokerPartitionInfo.kafka$producer$ZKBrokerPartitionInfo$$getZKTopicPartitionInfo(ZKBrokerPartitionInfo.scala:163)
 at
kafka.producer.ZKBrokerPartitionInfo.<init>(ZKBrokerPartitionInfo.scala:65)
 at kafka.producer.Producer.<init>(Producer.scala:47)
 at kafka.javaapi.producer.Producer.<init>(Producer.scala:33)
 at kafka.javaapi.producer.Producer.<init>(Producer.scala:40)
 at kafka.example.Producer.main(Producer.java:66)
Disconnected from the target VM, address: '127.0.0.1:49086', transport:
'socket'

Please advice

Thanks
Oleg.