You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "LCER (Jira)" <ji...@apache.org> on 2022/05/23 06:24:00 UTC

[jira] [Created] (FLINK-27738) instance KafkaSink support config topic properties

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)