[jira] [Commented] (FLINK-27828) FlinkKafkaProducer VS KafkaSink

2022-06-13 Thread Jiangfei Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553892#comment-17553892 ] Jiangfei Liu commented on FLINK-27828: -- checkpoint config:         CheckpointConfi

[jira] [Commented] (FLINK-27828) FlinkKafkaProducer VS KafkaSink

2022-06-13 Thread Jiangfei Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553891#comment-17553891 ] Jiangfei Liu commented on FLINK-27828: -- parallelism:3 checkpoint config:        

[jira] [Commented] (FLINK-27828) FlinkKafkaProducer VS KafkaSink

2022-06-06 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550752#comment-17550752 ] Qingsheng Ren commented on FLINK-27828: --- [~Jiangfei Liu] Could you share some cont

[jira] [Commented] (FLINK-27828) FlinkKafkaProducer VS KafkaSink

2022-05-30 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543975#comment-17543975 ] Martijn Visser commented on FLINK-27828: [~renqs] Any thoughts on this on how we