Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5335
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5335#discussion_r165045598
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@ -95,21
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5335#discussion_r165022709
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@ -95,21
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5335
(master) [FLINK-8419] [kafka] Register metrics for dynamically discovered
Kafka partitions
## What is the purpose of the change
This PR fixes that offset metrics (i.e. current offset,
