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, 16 Feb 2018 08:42:00 GMT

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

ASF GitHub Bot commented on FLINK-5728:

Github user aljoscha commented on the issue:

    I merged this, could you please close the PR? 👍 

> 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