Nigel Liang created KAFKA-13156:
-----------------------------------
Summary: KafkaStatusBackingStore making incorrect assumption about
order of task and connector delete events
Key: KAFKA-13156
URL: https://issues.apache.org/jira/browse/KAFKA-13156
Project: Kafka
Issue Type: Bug
Components: KafkaConnect
Reporter: Nigel Liang
Assignee: Nigel Liang
When a connector remove message is read from the status topic,
`KafkaStatusBackingStore` removes both the connector and associated tasks from
its connector and tasks cache. However, due to potentially partitioned nature
of the status topic, there is no guarantee about the order of delivery for the
connector removal message and task status messages for the same connector. If
the connector is rapidly removed and recreated, the status backing store may
see the task running events before the connector removal, in which case the
running tasks would be removed from the tasks cache.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)