[jira] [Closed] (STORM-692) KakfaSpout storage of offsets in Zookeeper lost

["Rick Kellogg (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/STORM-692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Rick Kellogg closed STORM-692.
------------------------------

> KakfaSpout storage of offsets in Zookeeper lost
> -----------------------------------------------
>
>                 Key: STORM-692
>                 URL: https://issues.apache.org/jira/browse/STORM-692
>             Project: Apache Storm
>          Issue Type: Bug
>          Components: storm-kafka
>    Affects Versions: 0.9.3
>            Reporter: Rick Kellogg
>            Assignee: Rick Kellogg
>
> Constructor for SpoutConfig and inadequate documentation in storm-kafka/README.md leads to lost persistence of Kafka offset information.
> The SpoutConfig class constructor takes four parameters:
> hosts - Zookeeper host & root path for Kafka 
> topic - Kafka topic name
> zkRoot - Zookeeper path for Kafka Spout offset
> id -- Identifier for KafkaSpout 
> Unfortunately it also exposes two public instance variables that must also be set: zkServers & zkPort.  If these two variables are not set it uses Storm default values(localhost & 2000) which cause the offset information to be lost.
> Suggest we replace the existing constructor with one that supplies all 6 required values.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)