Hai Zhou UTC+8 created FLINK-7758: ------------------------------------- Summary: Fix bug Kafka09Fetcher add offset metrics Key: FLINK-7758 URL: https://issues.apache.org/jira/browse/FLINK-7758 Project: Flink Issue Type: Bug Components: Kafka Connector Affects Versions: 1.3.2 Reporter: Hai Zhou UTC+8 Assignee: Hai Zhou UTC+8 Fix For: 1.4.0
in Kafka09Fetcher, add _KafkaConsumer_ kafkaMetricGroup. No judgment that the useMetrics variable is true. -- This message was sent by Atlassian JIRA (v6.4.14#64029)