[
https://issues.apache.org/jira/browse/KAFKA-17574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17574.
------------------------------------
Fix Version/s: 4.0.0
Assignee: Stig Rohde Døssing
Resolution: Fixed
> KafkaClusterTestKit produces error logs if shut down from a shutdown hook
> -------------------------------------------------------------------------
>
> Key: KAFKA-17574
> URL: https://issues.apache.org/jira/browse/KAFKA-17574
> Project: Kafka
> Issue Type: Bug
> Reporter: Stig Rohde Døssing
> Assignee: Stig Rohde Døssing
> Priority: Minor
> Fix For: 4.0.0
>
>
> I'd like to use KafkaClusterTestKit for running an embedded Kafka server in
> tests outside Kafka's own codebase. For most of my tests, I can reuse a
> single Kafka server, so I'd like to register a shutdown hook to terminate
> this instance.
> I've noticed an unfortunate interaction with the way TestKitNodes chooses a
> base directory for the nodes: It uses
> [TestUtils.tempDirectory|https://github.com/apache/kafka/blob/74bebf6e3dfdc9de6894d656bdbbb28a4c33eda8/clients/src/test/java/org/apache/kafka/test/TestUtils.java#L262],
> which registers its own shutdown hook to remove the directory on JVM exit.
> Since shutdown hooks run in arbitrary order, the tmp directory cleanup might
> run before the hook that terminates the KafkaClusterTestKit, which then
> causes noisy error logging.
> I think it would be nice if KafkaClusterTestKit supported this use case.
> Allowing the user to specify a directory for the test cluster would allow the
> caller to choose not to use TestUtils.tempDirectory in a case like this.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
