[
https://issues.apache.org/jira/browse/STORM-692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345150#comment-14345150
]
Rick Kellogg commented on STORM-692:
------------------------------------
Request merge on pull request. Thx.
> 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)
