hmit commented on PR #103: URL: https://github.com/apache/flink-connector-kafka/pull/103#issuecomment-2795888382
@tomncooper thanks for taking the time to look at it and providing feedback! I've updated the PR description with some details, is it possible to give this another look? The kafka connector very much still uses a kafka side consumer group to consume. In fact, the metrics from the said consumer are cherry-picked to be reported using Flink `MetricGroup` - `KafkaSourceReader.KafkaConsumer`. This is the relevant section from [flink docs](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#kafka-consumer-metrics) on the matter -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
