[ https://issues.apache.org/jira/browse/STORM-2434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Hugo Louro updated STORM-2434: ------------------------------ Component/s: (was: storm-kafka-client) > Storm spout is not reading/emitting data in storm cluster mode (version 1.0.0) > ------------------------------------------------------------------------------ > > Key: STORM-2434 > URL: https://issues.apache.org/jira/browse/STORM-2434 > Project: Apache Storm > Issue Type: Question > Components: storm-kafka > Affects Versions: 1.0.0 > Environment: ubuntu > Reporter: Minhaj Ahmad > > I am using apache storm 1.0.0 both in local as well as cluster mode. For the > spout, I am reading the data from kafka topic (I am using kafka > 2.11-0.8.2.1). Spout is reading the data from kafka topic and also emitting > the data when I am using storm in local mode but the storm spout is not > emitting any data when I am running storm in cluster mode. > My topology implementation for reading kafka data is as follow: > brokerHosts = new ZkHosts(kafkaZookeeper); > SpoutConfig kafkaConfig = new SpoutConfig(brokerHosts, kafkaTopicIn, "", > "storm"); > kafkaConfig.scheme = new SchemeAsMultiScheme(new StringScheme()); > TopologyBuilder builder = new TopologyBuilder(); > builder.setSpout("spout", new KafkaSpout(kafkaConfig), 2); > My storm configuration file: > storm.zookeeper.servers: > - "localhost" > storm.zookeeper.port: 2181 > nimbus.seeds: ["localhost"] > storm.local.dir: "/tmp/storm" > I am also not getting any error while submitting Storm topology in cluster > mode. > Any idea why topology spout is not emitting any data in cluster mode ?? > Any help would be greatly appreciated. -- This message was sent by Atlassian JIRA (v6.4.14#64029)