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)

Reply via email to