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)