[KAFKA-7798] Expose embedded client context from KafkaStreams threadMetadata

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.2.0
• Component/s: streams
• Labels: kip
• Assignee: Guozhang Wang
• Reporter: Guozhang Wang
• Created: 08/Jan/19 21:58
• Updated: 02/Feb/19 05:29
• Resolved: 02/Feb/19 05:29

Description

A KafkaStreams client today contains multiple embedded clients: producer, consumer and admin client. Currently these client's context like client id are not exposed via KafkaStreams. This ticket proposes to expose those context information at the per-thread basis (since each thread has its own embedded clients) via ThreadMetadata.

This also has an interplay with KIP-345: as we add group.instance.id in that KIP, this information should also be exposed as well.

Cf: https://cwiki.apache.org/confluence/display/KAFKA/KIP-414%3A+Expose+Embedded+ClientIds+in+Kafka+Streams

Issue Links

• links to: GitHub Pull Request #6107
• links to: KIP-414: Expose Embedded ClientIds in Kafka Streams
• mentioned in: Page Loading...
• mentioned in: Page Loading...