[ https://issues.apache.org/jira/browse/KAFKA-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Boyang Chen updated KAFKA-6896: ------------------------------- Description: We would like to also export the producer metrics from {{StreamThread}} just like consumer metrics, so that we could gain more visibility of stream application. The approach is to pass in the \{{threadProducer}}into the StreamThread so that we could export its metrics in dynamic. Note that this is a pure internal change that doesn't require a KIP, and in the future we also want to export admin client metrics. A followup KIP for admin client will be created once this is merged. Pull request here: https://github.com/apache/kafka/pull/4998 was: We would like to also export the producer metrics from {{StreamThread}} just like consumer metrics, so that we could gain more visibility of stream application. The approach is to pass in the {{threadProducer}}into the StreamThread so that we could export its metrics in dynamic. Note that this is a pure internal change that doesn't require a KIP, and in the future we also want to export admin client metrics. A followup KIP for admin client will be created once this is merged. > add producer metrics exporting in KafkaStreams.java > --------------------------------------------------- > > Key: KAFKA-6896 > URL: https://issues.apache.org/jira/browse/KAFKA-6896 > Project: Kafka > Issue Type: Improvement > Components: streams > Reporter: Boyang Chen > Assignee: Boyang Chen > Priority: Major > > We would like to also export the producer metrics from {{StreamThread}} just > like consumer metrics, so that we could gain more visibility of stream > application. The approach is to pass in the \{{threadProducer}}into the > StreamThread so that we could export its metrics in dynamic. > Note that this is a pure internal change that doesn't require a KIP, and in > the future we also want to export admin client metrics. A followup KIP for > admin client will be created once this is merged. > Pull request here: https://github.com/apache/kafka/pull/4998 -- This message was sent by Atlassian JIRA (v7.6.3#76005)