Description
This method creates a KafkaConsumer, but does not close it.
We can use a try-with-resources to ensure the consumer is closed prior to returning or throwing from this function.
Attachments
Issue Links
- Discovered while testing
-
KAFKA-15845 Add Junit5 test extension which detects leaked Kafka clients and servers
- In Progress
- links to