flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default
Date Fri, 23 Feb 2018 11:52:00 GMT

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

ASF GitHub Bot commented on FLINK-5728:

Github user tzulitai closed the pull request at:


> FlinkKafkaProducer should flush on checkpoint by default
> --------------------------------------------------------
>                 Key: FLINK-5728
>                 URL: https://issues.apache.org/jira/browse/FLINK-5728
>             Project: Flink
>          Issue Type: Improvement
>          Components: Kafka Connector
>            Reporter: Tzu-Li (Gordon) Tai
>            Assignee: Tzu-Li (Gordon) Tai
>            Priority: Major
>             Fix For: 1.5.0
> As discussed in FLINK-5702, it might be a good idea to let the FlinkKafkaProducer flush
on checkpoints by default. Currently, it is disabled by default.
> It's a very simple change, but we should think about whether or not we want to break
user behaviour, or have proper usage migration.

This message was sent by Atlassian JIRA

View raw message