Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/4769
@tzulitai , confirm.
because the `FlinkKafkaConsumer011` extend from `FlinkKafkaConsumer010`
and `Kafka010Fetcher` extend from `Kafka09Fetcher`, for Kafka connector only
need to fix
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4769
@yew1eb doesn't this also need to be fixed for Kafka connector versions
0.10 and 0.11?
---
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/4769
@zentol ping. I have updated this PR.
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4769
The current solution also straight up doesn't work:
```
java.lang.ClassCastException: java.lang.Object cannot be cast to
org.apache.flink.metrics.MetricGroup
at
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4769
As I said, it is better to return an `UnregisteredMetricsGroup`. The
current solution will blow up the moment the returned group is used, and can't
be guarded against with null checks.
---
