[ https://issues.apache.org/jira/browse/KAFKA-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chris Egerton reopened KAFKA-10873: ----------------------------------- Assignee: (was: Luke Chen) > Inaccurate "Ignoring stop request for unowned connector" log messages > --------------------------------------------------------------------- > > Key: KAFKA-10873 > URL: https://issues.apache.org/jira/browse/KAFKA-10873 > Project: Kafka > Issue Type: Bug > Components: KafkaConnect > Reporter: Chris Egerton > Priority: Major > > If a connector fails during startup, it will never be added to the worker's > internal list of running connectors (see > [https://github.com/apache/kafka/blob/87260a33b01590d0f73577840422e24fa589bed0/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java#L298|https://github.com/apache/kafka/blob/87260a33b01590d0f73577840422e24fa589bed0/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java#L298).]), > and the same happens for tasks (see > [https://github.com/apache/kafka/blob/87260a33b01590d0f73577840422e24fa589bed0/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java#L570]). > > This leads to the following {{WARN}}-level log messages when that > connector/task is scheduled to be stopped by the worker: > * [Ignoring stop request for unowned connector > <name>|https://github.com/apache/kafka/blob/87260a33b01590d0f73577840422e24fa589bed0/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java#L390] > * [Ignoring await stop request for non-present connector > <name>|https://github.com/apache/kafka/blob/87260a33b01590d0f73577840422e24fa589bed0/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java#L415] > * [Ignoring stop request for unowned task > <name>|https://github.com/apache/kafka/blob/87260a33b01590d0f73577840422e24fa589bed0/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java#L832] > * [Ignoring await stop request for non-present task > <name>|https://github.com/apache/kafka/blob/87260a33b01590d0f73577840422e24fa589bed0/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java#L862] > If the connector/task failed on startup, there should already be log messages > detailing the failure and its cause; there is no need to emit warning > messages about not stopping that connector when it is scheduled for shutdown. > Even worse, emitting these messages may cause users to believe that their > cluster is experiencing a rebalancing bug that is somehow causing > connectors/tasks that are not assigned to a worker to be revoked from it. -- This message was sent by Atlassian Jira (v8.3.4#803005)