Antti Järvinen created STORM-2426:
-------------------------------------
Summary: First tuples fail after worker is respawn
Key: STORM-2426
URL: https://issues.apache.org/jira/browse/STORM-2426
Project: Apache Storm
Issue Type: Bug
Components: storm-kafka-client
Affects Versions: 1.0.2
Reporter: Antti Järvinen
Attachments: 2017-03-20-Kafka-spout-issue.txt
Topology with two Kafka spouts (org.apache.storm.kafka.spout.KafkaSpout)
reading from two different topics.
1. Kill the only worker process for topology
2. Storm creates new worker
3. Kafka starts rebalancing (log line 15-16)
4. Kafka rebalancing done (log line 18-19)
5. Kafka topics read and tuples emitted (log line 28-29)
6. Tuples immediately fail (log line 30-33)
The delay between tuples emitted and tuples failing is just some 10 ms. No
bolts in topology received the tuples.
What could cause this?
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
