Apoorv Mittal created KAFKA-15662: ------------------------------------- Summary: 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 Reporter: Apoorv Mittal Assignee: Matthias J. Sax
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}} . ``` {{public}} {{ClientInstanceIds clientInstanceIds(Duration timeout);}} {{```}} -- This message was sent by Atlassian Jira (v8.20.10#820010)