[
https://issues.apache.org/jira/browse/FLINK-27738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541308#comment-17541308
]
Martijn Visser edited comment on FLINK-27738 at 5/24/22 7:24 AM:
-----------------------------------------------------------------
[~LCER] We should not let KafkaSink modify topic properties. They are two
separate operations, one is about creation and management of topic properties,
one is about writing data to that topic. KafkaSink's only responsibility is
about writing data to that topic, we should not use it for other operations.
It's also not KafkaSink that creates a topic, it's the operation involved in
the management of topic properties that allows for auto-creation of a topic.
was (Author: martijnvisser):
[~LCER] We should not let KafkaSink modify topic properties. They are two
separate operations, one is about creation and management of topic properties,
one is about writing data to that topic. KafkaSink's only responsibility is
about writing data to that topic, we should not use it for other operations.
> 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)
