[
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)
