[
https://issues.apache.org/jira/browse/KAFKA-15662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-15662:
--
Description:
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}
was:
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);}}
{{```}}
> 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
>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)
