[jira] [Created] (FLINK-4617) Kafka & Flink duplicate messages on restart

2016-09-13 Thread Matthew Barlocker (JIRA)
Matthew Barlocker created FLINK-4617: Summary: Kafka & Flink duplicate messages on restart Key: FLINK-4617 URL: https://issues.apache.org/jira/browse/FLINK-4617 Project: Flink Issue Type:

[jira] [Updated] (FLINK-4617) Kafka & Flink duplicate messages on restart

2016-09-13 Thread Matthew Barlocker (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew Barlocker updated FLINK-4617: - Affects Version/s: 1.0.1 1.0.2 1.0.3 > Kafka

[jira] [Commented] (FLINK-4617) Kafka & Flink duplicate messages on restart

2016-09-15 Thread Matthew Barlocker (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15493667#comment-15493667 ] Matthew Barlocker commented on FLINK-4617: -- Sounds good. Thanks! > Kafka & Flink

[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

2016-09-15 Thread Matthew Barlocker (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15493956#comment-15493956 ] Matthew Barlocker commented on FLINK-4618: -- Nice find [~melmoth] and [~tzulitai]