[jira] [Updated] (STORM-2434) Storm spout is not reading/emitting data in storm cluster mode (version 1.0.0)

["Hugo Louro (JIRA)" <ji...@apache.org>]

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