khiemvk created STORM-3531:
------------------------------
Summary: Kafka Spouts Lag error when worker die
Key: STORM-3531
URL: https://issues.apache.org/jira/browse/STORM-3531
Project: Apache Storm
Issue Type: Bug
Components: storm-kafka-client
Affects Versions: 1.2.3
Environment: Linux
Reporter: khiemvk
I deploy topology on cluster (3 Supervisors) with 3 workers, 3 Spouts read
topic kafka with 3 partitions.
Step 1: I kill worker1 on Supervisor1
Step 2: Worker1 automatic running again.
Step 3: Kafka spout of worker1 register partition 1 and read not lag. Worker2
and worker3 error lag kafka, not continue read and commit offset
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
