[
https://issues.apache.org/jira/browse/KAFKA-15662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15662:
------------------------------------
Component/s: streams
> Implement support for clientInstanceIds in Kafka Stream
> -------------------------------------------------------
>
> Key: KAFKA-15662
> URL: https://issues.apache.org/jira/browse/KAFKA-15662
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: Apoorv Mittal
> Assignee: Matthias J. Sax
> Priority: Major
>
> The KIP requires Kafka Stream to support below method to give access to the
> client instance ids of the producers, consumers and admin clients used by
> Kafka Streams.
>
> This method is only permitted when Kafka Streams is in state RUNNING or
> REBALANCING. In the event that Kafka Streams is not in state RUNNING or
> REBALANCING, the method throws
> {{org.apache.kafka.streams.errors.StreamsNotRunningException}} , which is a
> new subclass of {{InvalidStateStoreException}} .
>
> {code:java}
> public ClientInstanceIds clientInstanceIds(Duration timeout); {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
