[KAFKA-6896] add producer metrics exporting in KafkaStreams.java

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.0.0
• Component/s: streams
• Assignee: Boyang Chen
• Reporter: Boyang Chen
• Reviewer: Matthias J. Sax
• Created: 11/May/18 02:41
• Updated: 15/May/18 21:29
• Resolved: 15/May/18 21:29

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

Issue Links

• links to: GitHub Pull Request #4998