[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585169#comment-17585169 ] zhilinli commented on FLINK-25336: -- Is the ultimate solution only to upgrade Kafkfa? >

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597186#comment-17597186 ] Martijn Visser commented on FLINK-25336: [~sunnny] Yes > Kafka connector compat

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460387#comment-17460387 ] Yuan Zhu commented on FLINK-25336: -- The cause of this exception is invoked by the logic

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460391#comment-17460391 ] Yuan Zhu commented on FLINK-25336: -- Hi, [~becket_qin]. What's the purpose here? Can we

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460395#comment-17460395 ] JasonLee commented on FLINK-25336: -- [~straw] In fact, this is because the version of Ka

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460431#comment-17460431 ] Yuan Zhu commented on FLINK-25336: -- [~JasonLee] Why not make it configurable to support

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460465#comment-17460465 ] Martijn Visser commented on FLINK-25336: [~straw] This version is not supported

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460493#comment-17460493 ] Yuan Zhu commented on FLINK-25336: -- [~MartijnVisser] Thanks. Then what you provided is

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460512#comment-17460512 ] Martijn Visser commented on FLINK-25336: [~straw] Thanks for pointing that out,

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460562#comment-17460562 ] Yuan Zhu commented on FLINK-25336: -- [~MartijnVisser]  [~JasonLee] Thanks for your help.