[ https://issues.apache.org/jira/browse/FLINK-27738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540791#comment-17540791 ]
Martijn Visser commented on FLINK-27738: ---------------------------------------- [~LCER] Given the documentation on additional properties at https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#additional-properties can you elaborate on what you find missing? > 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 > Priority: Major > > 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)