[FLINK-16520] Move Kafka client properties resolution in KafkaSinkProvider to KafkaEgressBuilder

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: statefun-2.0.0
• Fix Version/s: statefun-3.1.0
• Component/s: Stateful Functions
• Labels: auto-unassigned
• Assignee: Tzu-Li (Gordon) Tai
• Reporter: Tzu-Li (Gordon) Tai
• Created: 10/Mar/20 08:13
• Updated: 28/May/21 07:37
• Resolved: 28/May/21 07:37

Description

We've moved Kafka client properties resolution from the KafkaSourceProvider to be consolidated in the KafkaIngressBuilder in FLINK-15769.

The same should also be done for the producer side, i.e. for KafkaSinkProvider, by moving the properties resolution logic to KafkaEgressBuilder.