[FLINK-34337] Sink.InitContextWrapper should implement metadataConsumer method

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.19.0
• Fix Version/s: 1.19.0
• Component/s: API / Core
• Labels: pull-request-available
• Assignee: jiabao.sun
• Reporter: jiabao.sun
• Created: 02/Feb/24 05:49
• Updated: 06/Feb/24 19:20
• Resolved: 06/Feb/24 19:20

Description

Sink.InitContextWrapper should implement metadataConsumer method.

If the metadataConsumer method is not implemented, the behavior of the wrapped WriterInitContext's metadataConsumer will be lost.

Issue Links

• is related to: FLINK-34192 Update flink-connector-kafka to be compatible with updated SinkV2 interfaces
• links to: GitHub Pull Request #24249
• mentioned in: Page Loading...