[jira] [Commented] (FLINK-9846) Add a Kafka table sink factory

[ASF GitHub Bot (JIRA)]

    [ 
https://issues.apache.org/jira/browse/FLINK-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16552637#comment-16552637
 ] 

ASF GitHub Bot commented on FLINK-9846:
---------------------------------------

Github user pnowojski commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6387#discussion_r204346197
  
    --- Diff: 
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka08JsonTableSink.java
 ---
    @@ -84,7 +93,14 @@ public Kafka08JsonTableSink(String topic, Properties 
properties, KafkaPartitione
     
        @Override
        protected FlinkKafkaProducerBase<Row> createKafkaProducer(String topic, 
Properties properties, SerializationSchema<Row> serializationSchema, 
FlinkKafkaPartitioner<Row> partitioner) {
    -           return new FlinkKafkaProducer08<>(topic, serializationSchema, 
properties, partitioner);
    +           final FlinkKafkaProducerBase<Row> kafkaProducer = new 
FlinkKafkaProducer08<>(
    +                   topic,
    +                   serializationSchema,
    +                   properties,
    +                   partitioner);
    +           // always enable flush on checkpoint to achieve at-least-once 
if query runs with checkpointing enabled.
    --- End diff --
    
    ditto


> Add a Kafka table sink factory
> ------------------------------
>
>                 Key: FLINK-9846
>                 URL: https://issues.apache.org/jira/browse/FLINK-9846
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table API &amp; SQL
>            Reporter: Timo Walther
>            Assignee: Timo Walther
>            Priority: Major
>              Labels: pull-request-available
>
> FLINK-8866 implements a unified way of creating sinks and using the format 
> discovery for searching for formats (FLINK-8858). It is now possible to add a 
> Kafka table sink factory for streaming environment that uses the new 
> interfaces.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)