[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624290#comment-17624290
]
hongcha commented on FLINK-29674:
-
[~martijnvisser] [~coderap] I looked at the part of t
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621432#comment-17621432
]
hongcha edited comment on FLINK-29674 at 10/21/22 1:37 AM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621432#comment-17621432
]
hongcha edited comment on FLINK-29674 at 10/21/22 1:15 AM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621432#comment-17621432
]
hongcha commented on FLINK-29674:
-
[~coderap] this is my test source code:
{code:java
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hongcha updated FLINK-29674:
Affects Version/s: 1.15.2
> Apache Kafka Connector‘s “ setBounded” not valid
> ---
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619495#comment-17619495
]
hongcha commented on FLINK-29674:
-
Hi [~martijnvisser] ,I'm try in 1.15.2 version,but Th
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hongcha updated FLINK-29674:
Attachment: image-2022-10-18-20-38-34-515.png
> Apache Kafka Connector‘s “ setBounded” not valid
> ---
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619316#comment-17619316
]
hongcha commented on FLINK-29674:
-
OK,i’m try to verify this with the current 1.15.2
>
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619306#comment-17619306
]
hongcha commented on FLINK-29674:
-
Hi [~martijnvisser] i'm using Flink1.15.0
> Apache K
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hongcha updated FLINK-29674:
Description:
When I'm using the Kafka connector, and to set kafka's consumption boundary ("
setBounded ")
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hongcha updated FLINK-29674:
Summary: Apache Kafka Connector‘s “ setBounded” not valid (was: Apache
Kafka 连接器的“ setBounded”不生效)
> Apa
11 matches
Mail list logo