[geomesa-users] Kafka error

["Ngo, James T." <James.Ngo@xxxxxxxxx>]

Hi,

 

I’ve been experimenting Geomesa-osm Tutorials. I’m able to build the project with Accumulo 1.6. However I’m running into an issue with Kakfa producer.

 

    java –cp geomesa-osm-accumulo1.5-1.0-SNAPSHOT.jar geomesa.osm.OSMingestProducer –ingestFile /tmp/data1 –topic OSM –brokers 0,1,2

 

 

Exception in thread "main" java.lang.NullPointerException

        at scala.Predef$.Integer2int(Predef.scala:392)

        at kafka.client.ClientUtils$$anonfun$parseBrokerList$1.apply(ClientUtils.scala:103)

        at kafka.client.ClientUtils$$anonfun$parseBrokerList$1.apply(ClientUtils.scala:102)

        at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)

        at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)

        at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)

        at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)

        at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)

        at scala.collection.AbstractTraversable.map(Traversable.scala:105)

        at kafka.client.ClientUtils$.parseBrokerList(ClientUtils.scala:102)

        at kafka.producer.BrokerPartitionInfo.<init>(BrokerPartitionInfo.scala:32)

        at kafka.producer.async.DefaultEventHandler.<init>(DefaultEventHandler.scala:41)

        at kafka.producer.Producer.<init>(Producer.scala:60)

        at kafka.javaapi.producer.Producer.<init>(Producer.scala:26)

        at geomesa.osm.OSMIngestProducer.main(OSMIngestProducer.java:60)

 

Anyone is having the same issue like this?

 

Thanks.

 

James