[
https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502129#comment-17502129
]
Fabian Paul commented on FLINK-26126:
-
Merged in master: 9725933fc0a09274801d2acb52a6a5256afa10f6
>
[
https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493424#comment-17493424
]
Jing Ge commented on FLINK-26126:
-
It seems fine that KafkaWriter uses the Counter metric from
[
https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493213#comment-17493213
]
Jing Ge commented on FLINK-26126:
-
reference: the specific commit of the disabled test
[
https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492430#comment-17492430
]
Fabian Paul commented on FLINK-26126:
-
I plan to work on this today or respectively tomorrow. It is
[
https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492390#comment-17492390
]
Hang Ruan commented on FLINK-26126:
---
The Kafka sink is already using the sink v2 interface in the
[
https://issues.apache.org/jira/browse/FLINK-26126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492357#comment-17492357
]
Leonard Xu commented on FLINK-26126:
[~ruanhang1993] The blocker priority means we have to fix to
