LCER created FLINK-27738:
----------------------------
Summary: instance KafkaSink support config topic properties
Key: FLINK-27738
URL: https://issues.apache.org/jira/browse/FLINK-27738
Project: Flink
Issue Type: Improvement
Components: Connectors / Kafka
Affects Versions: 1.15.0
Reporter: LCER
I use KafkaSink to config Kafka information as following:
*KafkaSink.<String>builder()*
*.setBootstrapServers(brokers)*
*.setRecordSerializer(KafkaRecordSerializationSchema.builder()*
*.setTopicSelector(topicSelector)*
*.setValueSerializationSchema(new SimpleStringSchema())*
*.build()*
*)*
*.setDeliverGuarantee(DeliveryGuarantee.EXACTLY_ONCE)*
*.setKafkaProducerConfig(properties)*
*.build();*
*----------------*
*I can't find any method to support config topic properties*
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
