[
https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6996:
---
Fix Version/s: 1.4.0
> FlinkKafkaProducer010 doesn't guarantee at-least-once semantic
[
https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6996:
---
Priority: Blocker (was: Major)
> FlinkKafkaProducer010 doesn't guarantee at-least-onc
[
https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6996:
---
Fix Version/s: 1.3.2
> FlinkKafkaProducer010 doesn't guarantee at-least-once semantic
[
https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-6996:
--
Description: FlinkKafkaProducer010 doesn't implement CheckpointedFunction
interface. This means,
