lhotari opened a new issue, #15853: URL: https://github.com/apache/pulsar/issues/15853
**Describe the bug** Resources are leaked in Pulsar IO tests. This type of entries repeat in the test logs: ``` 2022-05-31T06:06:42,491 - WARN - [kafka-coordinator-heartbeat-thread | sink-test-fyeeijxp:NetworkClient@782] - [Consumer clientId=consumer-sink-test-fyeeijxp-1, groupId=sink-test-fyeeijxp] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:42,674 - WARN - [kafka-producer-network-thread | c9eafaa1-fee0-4029-a05d-55b0c639cb3e:NetworkClient@782] - [Producer clientId=c9eafaa1-fee0-4029-a05d-55b0c639cb3e] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:43,367 - WARN - [kafka-coordinator-heartbeat-thread | sink-test-fyeeijxp:NetworkClient@782] - [Consumer clientId=consumer-sink-test-fyeeijxp-1, groupId=sink-test-fyeeijxp] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:43,834 - WARN - [kafka-producer-network-thread | c9eafaa1-fee0-4029-a05d-55b0c639cb3e:NetworkClient@782] - [Producer clientId=c9eafaa1-fee0-4029-a05d-55b0c639cb3e] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:44,359 - WARN - [kafka-coordinator-heartbeat-thread | sink-test-fyeeijxp:NetworkClient@782] - [Consumer clientId=consumer-sink-test-fyeeijxp-1, groupId=sink-test-fyeeijxp] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:44,748 - WARN - [kafka-producer-network-thread | c9eafaa1-fee0-4029-a05d-55b0c639cb3e:NetworkClient@782] - [Producer clientId=c9eafaa1-fee0-4029-a05d-55b0c639cb3e] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:45,285 - WARN - [kafka-coordinator-heartbeat-thread | sink-test-fyeeijxp:NetworkClient@782] - [Consumer clientId=consumer-sink-test-fyeeijxp-1, groupId=sink-test-fyeeijxp] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:45,603 - WARN - [kafka-producer-network-thread | c9eafaa1-fee0-4029-a05d-55b0c639cb3e:NetworkClient@782] - [Producer clientId=c9eafaa1-fee0-4029-a05d-55b0c639cb3e] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:46,457 - WARN - [kafka-coordinator-heartbeat-thread | sink-test-fyeeijxp:NetworkClient@782] - [Consumer clientId=consumer-sink-test-fyeeijxp-1, groupId=sink-test-fyeeijxp] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:46,708 - WARN - [kafka-producer-network-thread | c9eafaa1-fee0-4029-a05d-55b0c639cb3e:NetworkClient@782] - [Producer clientId=c9eafaa1-fee0-4029-a05d-55b0c639cb3e] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:47,494 - WARN - [kafka-coordinator-heartbeat-thread | sink-test-fyeeijxp:NetworkClient@782] - [Consumer clientId=consumer-sink-test-fyeeijxp-1, groupId=sink-test-fyeeijxp] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:47,863 - WARN - [kafka-producer-network-thread | c9eafaa1-fee0-4029-a05d-55b0c639cb3e:NetworkClient@782] - [Producer clientId=c9eafaa1-fee0-4029-a05d-55b0c639cb3e] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. 2022-05-31T06:06:48,409 - WARN - [kafka-coordinator-heartbeat-thread | sink-test-fyeeijxp:NetworkClient@782] - [Consumer clientId=consumer-sink-test-fyeeijxp-1, groupId=sink-test-fyeeijxp] Connection to node 1 (localhost/127.0.0.1:49216) could not be established. Broker may not be available. ``` **To Reproduce** Check the output of "[CI - System - Pulsar IO](https://github.com/apache/pulsar/runs/6664811881?check_suite_focus=true#logs)" **Expected behavior** Resources should be properly closed in tests using try-with-resources blocks or Lombok's `@Cleanup` annotation. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
