[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334223#comment-17334223 ] Flink Jira Bot commented on FLINK-7913: --- This issue was marked "stale-assigned" and

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17323605#comment-17323605 ] Flink Jira Bot commented on FLINK-7913: --- This issue is assigned but has not receive

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383267#comment-16383267 ] Tzu-Li (Gordon) Tai commented on FLINK-7913: Yes, moving to 1.6.0. > Add supp

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16382135#comment-16382135 ] Aljoscha Krettek commented on FLINK-7913: - [~tzulitai] Did we decide to move this

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16289884#comment-16289884 ] Konstantin Lalafaryan commented on FLINK-7913: -- [~tzulitai] So it means in th

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286782#comment-16286782 ] Tzu-Li (Gordon) Tai commented on FLINK-7913: As a side note for clarification:

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286799#comment-16286799 ] Tzu-Li (Gordon) Tai commented on FLINK-7913: We should probably take that into

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286705#comment-16286705 ] Tzu-Li (Gordon) Tai commented on FLINK-7913: [~aljoscha] [~klalafaryan] Yes. I

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286706#comment-16286706 ] Tzu-Li (Gordon) Tai commented on FLINK-7913: This issue seems to troubling qui

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286189#comment-16286189 ] Aljoscha Krettek commented on FLINK-7913: - [~tzulitai] I think you also already th

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285816#comment-16285816 ] Konstantin Lalafaryan commented on FLINK-7913: -- - Kafka uses round-robin part

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262932#comment-16262932 ] Aljoscha Krettek commented on FLINK-7913: - What is the default Kafka partitioner d

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262244#comment-16262244 ] Konstantin Lalafaryan commented on FLINK-7913: -- [~aljoscha], [~tzulitai] do y

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224747#comment-16224747 ] Aljoscha Krettek commented on FLINK-7913: - That seems weird, I think we should pro

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16223340#comment-16223340 ] Konstantin Lalafaryan commented on FLINK-7913: -- [~aljoscha] What do you think

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16218776#comment-16218776 ] Konstantin Lalafaryan commented on FLINK-7913: -- Thanks for your comment. Yes,

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16218556#comment-16218556 ] Aljoscha Krettek commented on FLINK-7913: - This issue aims at using vanilla Kafka