question Re: Kafka spout cannot read from kafka topic in Archives of Support Questions (Read Only)

Kafka spout cannot read from kafka topic

seyma_menjour — Fri, 10 Feb 2017 19:47:58 GMT

Hey guys, I'm pretty new to kafka and storm and I'm trying to run the kafka-storm-hive-integration project from git

I packaged the project and run the storm jar command but I keep having this error :

s.k.PartitionManager - Read partition information from: /namenode:6667/id7/partition_1 --> null

No partition information found, using configuration to determine offset

this is the topology.properties:

zkhost = namenode:2181

inputTopic = inputtest

KafkaBroker = namenode:6667

consumerGroup= id7

metaStoreURI = thrift://namenode:9083

dbName = default

tblName = test

Really I don't know where to begin, can anyone guide me through this issue and I'll send further informations about the code ? thanks

sandyy006 — Fri, 10 Feb 2017 19:51:43 GMT

ambud_sharma1 — Sat, 11 Feb 2017 02:36:14 GMT

seyma_menjour — Mon, 13 Feb 2017 16:02:22 GMT

I've created it, I think there is a problem in the zkroot, I don't know how to configure it

seyma_menjour — Mon, 13 Feb 2017 18:45:59 GMT

Hey guys I found the error, :

when executing the storm jar command, we have to specify a topology name (whatever it is ) ex:

storm jar kafka-storm-integration-0.0.1-SNAPSHOT.jar com.storm.topology.KafkaTopology topology.properties testTopo

It wasn't specified in the readme.md. Any way thank you guys ^^