[ https://issues.apache.org/jira/browse/KAFKA-13156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sagar Rao reassigned KAFKA-13156: --------------------------------- Assignee: Sagar Rao (was: Chris Egerton) > 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: Sagar Rao > Priority: Minor > > 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.20.10#820010)