[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624290#comment-17624290
]
hongcha commented on FLINK-29674:
-
[~martijnvisser] [~coderap] I looked at the part of the source code,
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621432#comment-17621432
]
hongcha commented on FLINK-29674:
-
[~coderap] this is my test source code:
{code:java}
package test;
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621171#comment-17621171
]
CodeRap commented on FLINK-29674:
-
Cloud you paste your test source code ? [~jiagnwei]
> Apache Kafka
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17620123#comment-17620123
]
Martijn Visser commented on FLINK-29674:
[~renqs] Any idea?
> Apache Kafka Connector‘s “
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619495#comment-17619495
]
hongcha commented on FLINK-29674:
-
Hi [~martijnvisser] ,I'm try in 1.15.2 version，but There are still
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619316#comment-17619316
]
hongcha commented on FLINK-29674:
-
OK，i’m try to verify this with the current 1.15.2
> Apache Kafka
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619315#comment-17619315
]
Martijn Visser commented on FLINK-29674:
Can you please verify this with the latest Flink 1.15?
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619306#comment-17619306
]
hongcha commented on FLINK-29674:
-
Hi [~martijnvisser] i'm using Flink1.15.0
> Apache Kafka Connector‘s
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17619287#comment-17619287
]
Martijn Visser commented on FLINK-29674:
[~jiagnwei] Which Flink version are you using?
>
