[
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)
