[
https://issues.apache.org/jira/browse/KAFKA-9472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17023280#comment-17023280
]
Konstantine Karantasis commented on KAFKA-9472:
-----------------------------------------------
I overlooked the backing stores. But, yes, I'm suspecting a common root cause,
which has to do with the fact that we don't remove the task from the config
backing store, which would be reflected to the status backing store. More
investigation might be granted, that's why I didn't close the ticket. But I
wanted to bring up that this sounded relevant to KAFKA-8869.
> Reducing number of tasks for connector causes deleted tasks to show as
> UNASSIGNED
> ---------------------------------------------------------------------------------
>
> Key: KAFKA-9472
> URL: https://issues.apache.org/jira/browse/KAFKA-9472
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 2.0.0, 2.0.1, 2.1.0, 2.2.0, 2.1.1, 2.3.0, 2.2.1, 2.2.2,
> 2.4.0, 2.3.1
> Reporter: Chris Egerton
> Priority: Major
>
> If a connector is successfully created with {{t1}} running tasks and then
> reconfigured to use {{t1 - n}} tasks (where {{t1}} and {{n}} are both whole
> numbers and {{n}} is strictly less than {{t1}}), the connector should then
> list {{t1 - n}} total tasks in its status (which can be queried via the
> {{/connectors/:name:/status}} endpoint or the {{/connectors}} endpoint with
> the {{expand}} URL query parameter set to {{status}}).
> However, the connector will instead continue to list {{t1}} total tasks in
> its status, with {{n}} of them being listed as {{UNASSIGNED}} and the
> remaining {{t1 - n}} of them being listed as {{STARTED}}.
> This is because the only time a task status is removed from the status
> backing store (as opposed to simply being updated to {{UNASSIGNED}}) is when
> its connector is deleted. See relevant code snippets from the
> [AbstractHerder|https://github.com/apache/kafka/blob/df13fc93d0aebfe0ecc40dd4af3c5fb19b35f710/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java#L187-L192]
> and
> [DistributedHerder|https://github.com/apache/kafka/blob/df13fc93d0aebfe0ecc40dd4af3c5fb19b35f710/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java#L1511-L1520]
> classes.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
