Github user tzulitai closed the pull request at:
https://github.com/apache/flink/pull/5336
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5336#discussion_r165023649
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@ -92,21
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5336#discussion_r165023129
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@ -92,21
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5336#discussion_r165022738
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@ -92,21
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5336#discussion_r165021513
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@ -92,21
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5336#discussion_r165021339
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java
---
@@
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5336
(release-1.4) [FLINK-8419] [kafka] Register metrics for dynamically
discovered Kafka partitions
## What is the purpose of the change
Different version of #5335, which is targeted for
