Rick Kellogg created STORM-692:
----------------------------------
Summary: 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
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)
