You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/10/20 21:01:00 UTC

[jira] [Created] (KAFKA-15662) Implement support for clientInstanceIds in Kafka Stream

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)