[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=15224620#comment-15224620 ] Robert Metzger commented on FLINK-3343: --- How much heap size do you allocate per task

[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=15224598#comment-15224598 ] Robert Metzger commented on FLINK-3343: --- Have you tried setting a batch size of 0 ?

[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=15206537#comment-15206537 ] Robert Metzger commented on FLINK-3343: --- Has this issue been resolved? > Exception

[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=15136933#comment-15136933 ] Robert Metzger commented on FLINK-3343: --- Can you maybe ask on the u...@kafka.apache.

[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=15135743#comment-15135743 ] Robert Metzger commented on FLINK-3343: --- Where did you see that the default value is

[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=15134169#comment-15134169 ] Stephan Ewen commented on FLINK-3343: - Not sure if Flink can figure this out smartly.

[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=15134110#comment-15134110 ] Robert Metzger commented on FLINK-3343: --- No problem. lets use this jira to figure ou

[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] [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=15134098#comment-15134098 ] Robert Metzger commented on FLINK-3343: --- This is your second JIRA which is more of a

[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=15134095#comment-15134095 ] Robert Metzger commented on FLINK-3343: --- Can you try setting the {{batch.size}} to "