Greg Harris created KAFKA-17207:
-----------------------------------
Summary: ConnectWorkerIntegrationTest.testRequestTimeouts times
out in stop(), leaking clients
Key: KAFKA-17207
URL: https://issues.apache.org/jira/browse/KAFKA-17207
Project: Kafka
Issue Type: Test
Components: connect
Reporter: Greg Harris
The testRequestTimeouts deletes the internal config topic, putting the connect
workers into a bad state. When the test goes to clean up, it calls
DistributedHerder#stop, which waits for the herder executor to stop. This times
out, because the herder executor is blocked closing the
KafkaConfigBackingStore's producer. This log message gets printed:
{noformat}
[2024-07-26 11:52:50,817] ERROR Executor
java.util.concurrent.ThreadPoolExecutor@7ae97a58[Shutting down, pool size = 1,
active threads = 1, queued tasks = 0, completed tasks = 0] did not terminate in
time (org.apache.kafka.common.utils.ThreadUtils:83){noformat}
This effectively leaks the Kafka clients for the workers' internal topics, and
the herder executor thread. Instead, either the producer should not block
indefinitely on a missing topic, or the cluster state should be healed enough
for the producer to shutdown cleanly.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
