[
https://issues.apache.org/jira/browse/FLINK-27738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541029#comment-17541029
]
LCER commented on FLINK-27738:
------------------------------
[~martijnvisser] ，thank you for your reply , In your provide url,Kafka Sink
section hasn't introduce how to add properties ; I find class
org.apache.flink.connector.kafka.sink.KafkaSinkBuilder only declare
setKafkaProducerConfig method , this method support properties which declare in
org.apache.kafka.clients.producer.ProducerConfig class; but I want to customer
topic properties which declare in org.apache.kafka.common.config.TopicConfig,
so I didn't konw how to realize my function.
> 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)
