[jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224633#comment-15224633 ] Farouk Salem commented on FLINK-3343: - I use the default values. > Exception while us

[jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224606#comment-15224606 ] Farouk Salem commented on FLINK-3343: - yeah, it works most of the time. But, sometimes

[jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208659#comment-15208659 ] Farouk Salem commented on FLINK-3343: - Hi Robert, I still have this problem but it ha

[jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136945#comment-15136945 ] Farouk Salem commented on FLINK-3343: - Thanks. I will send an email right now :) > Ex

[jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135756#comment-15135756 ] Farouk Salem commented on FLINK-3343: - Sorry, I checked an old version of kafka docume

[jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15134481#comment-15134481 ] Farouk Salem commented on FLINK-3343: - Thanks for your replies. I decreased the batch

[jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15134111#comment-15134111 ] Farouk Salem commented on FLINK-3343: - By the way, I opened this as "improvement" beca

[jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15134108#comment-15134108 ] Farouk Salem commented on FLINK-3343: - Thanks a lot for your reply and sorry for misun

[jira] [Created] (FLINK-3343) Exception while using Kafka 0.9 connector

Farouk Salem created FLINK-3343: --- Summary: Exception while using Kafka 0.9 connector Key: FLINK-3343 URL: https://issues.apache.org/jira/browse/FLINK-3343 Project: Flink Issue Type: Improvemen

[jira] [Closed] (FLINK-3326) Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic

[ https://issues.apache.org/jira/browse/FLINK-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Farouk Salem closed FLINK-3326. --- Resolution: Invalid > Kafka Consumer doesn't retrieve messages after killing flink job which was > us

[jira] [Commented] (FLINK-3326) Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic

[ https://issues.apache.org/jira/browse/FLINK-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130590#comment-15130590 ] Farouk Salem commented on FLINK-3326: - Thanks for your super fast replies. Regarding u

[jira] [Created] (FLINK-3326) Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic

Farouk Salem created FLINK-3326: --- Summary: Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic Key: FLINK-3326 URL: https://issues.apache.org/jira/browse/FLINK-3326