Alexey Raga created STORM-391:
---------------------------------
Summary: KafkaSpout to await for the topic
Key: STORM-391
URL: https://issues.apache.org/jira/browse/STORM-391
Project: Apache Storm (Incubating)
Issue Type: Improvement
Affects Versions: 0.9.2-incubating
Reporter: Alexey Raga
When topic does not yet exist and the consumer is asked to consume from it, the
default behaviour for Kafka heigh-level consumer is to "await" for the topic
without a failure.
KafkaSpout currently fails trying to get the partition information about the
topic that does not exist.
It may be a good idea to have the same common behaviour in KafkaSpout and it
can probably be implemented through the zookeeper watchers: if topic does not
exist, then set up a watcher and don't do anything until it yields.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
