[FLINK-28370] Add close method for KafkaRecordSerializationSchema

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.14.5, 1.15.0
• Component/s: Connectors / Kafka
• Labels: pull-request-available stale-assigned
• Assignee: Ruan Hang
• Reporter: Leonard Xu
• Created: 04/Jul/22 07:02
• Updated: 11/Oct/23 18:54

Description

KafkaRecordSerializationSchema only offers open() method, we should offer close() method to release the opened resources.

Issue Links

• is related to: FLINK-22902 Port KafkaSink to new Unified Sink API (FLIP-143)
• links to: GitHub Pull Request #20164