Tzu-Li (Gordon) Tai created FLINK-16520: -------------------------------------------
Summary: Move Kafka client properties resolution in KafkaSinkProvider to KafkaEgressBuilder Key: FLINK-16520 URL: https://issues.apache.org/jira/browse/FLINK-16520 Project: Flink Issue Type: Improvement Components: Stateful Functions Affects Versions: statefun-1.1 Reporter: Tzu-Li (Gordon) Tai 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}}. -- This message was sent by Atlassian Jira (v8.3.4#803005)