Simon Schall created KAFKA-13631:
------------------------------------
Summary: Warning "Ignoring await stop request for non-present
connector..." when shuting down connector via API in distributed mode
Key: KAFKA-13631
URL: https://issues.apache.org/jira/browse/KAFKA-13631
Project: Kafka
Issue Type: Bug
Components: KafkaConnect
Affects Versions: 2.8.1
Reporter: Simon Schall
Attachments: connect-1.log
* S{color:#172b4d}etup: kafka with version 2.8.1 with scala version 2.13{color}
* {color:#172b4d}Start zookeeper, kafka server and
kafka-connect-distributed{color}
* {color:#172b4d}Create a FileStreamSinkConnector (e.g. via the following
request:{color}
{color:#000000}curl --location --request PUT
{color}{color:#2a00ff}'localhost:8083/connectors/local-file-sink/config'{color}{color:#000000}
\
--header {color}{color:#2a00ff}'Content-Type:
application/json'{color}{color:#000000} \
--data-raw {color}{color:#2a00ff}'{{color}
{color:#2a00ff}"name"{color}{color:#000000}:{color}{color:#2a00ff}"local-file-sink"{color}{color:#000000},{color}
{color:#2a00ff}"connector.class"{color}{color:#000000}:{color}{color:#2a00ff}"FileStreamSink"{color}{color:#000000},{color}
{color:#2a00ff}"tasks.max"{color}{color:#000000}:{color}{color:#098658}1{color}{color:#000000},{color}
{color:#2a00ff}"file"{color}{color:#000000}:{color}{color:#2a00ff}"test.sink.txt"{color}{color:#000000},{color}
{color:#2a00ff}"topics"{color}{color:#000000}:{color}{color:#2a00ff}"connect-test"{color}
}'
* {color:#172b4d}shutdown the connector via the api as followed:{color}
curl --location --request DELETE
'{color:#2a00ff}localhost:8083/connectors/local-file-sink/'{color}
In the log of connect-distributed will appear the following warnings (for
complete log see attachement, warning appears in l.2103ff. ):
{color:#172b4d}[2022-01-28 10:52:42,246] INFO Stopping connector
local-file-sink (org.apache.kafka.connect.runtime.Worker:382)
[2022-01-28 10:52:42,247] WARN Ignoring stop request for unowned connector
local-file-sink (org.apache.kafka.connect.runtime.Worker:385)
[2022-01-28 10:52:42,247] WARN Ignoring await stop request for non-present
connector local-file-sink (org.apache.kafka.connect.runtime.Worker:410){color}
{color:#172b4d}In the log it looks like, it is tried twice to stop the
connector. The first attempt is successful (log l.2096ff.), but the second
attempt causes the warning, as the connector is already stopped. It is not
traceable for us why the connector is tried to stop twice, but it seems to be
wrong.{color}
{color:#172b4d}Furthermore, the problem also occurs with any other connector we
tried so far, so it is not specific to the FileStreamSinkConnector.{color}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
