[ https://issues.apache.org/jira/browse/KAFKA-17202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Matthias J. Sax reassigned KAFKA-17202: --------------------------------------- Assignee: TengYao Chi > EosIntegrationTest.verifyChangelogMaxRecordOffsetMatchesCheckpointedOffset > leaks consumers > ------------------------------------------------------------------------------------------ > > Key: KAFKA-17202 > URL: https://issues.apache.org/jira/browse/KAFKA-17202 > Project: Kafka > Issue Type: Test > Components: streams > Affects Versions: 3.9.0 > Reporter: Greg Harris > Assignee: TengYao Chi > Priority: Major > Labels: newbie > > 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. -- This message was sent by Atlassian Jira (v8.20.10#820010)