[
https://issues.apache.org/jira/browse/STORM-692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rick Kellogg resolved STORM-692.
--------------------------------
Resolution: Invalid
Determined that loss of offset storage in Zookeeper was related to not calling
ack on OutputCollector. The instance variables do NOT need to be set for Kafka
Spout to work correctly.
> 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)
