THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
/** * @return the clients' assigned instance ids used for metrics collection. * @throws StreamsNotStartedExceptionIllegalStateException Indicates that Kafka Streams is not running. * @throws StreamsStoppedException Indicates Indicates that Kafka Streams is not running. * @throws TimeoutException IndicatesIndicates that a request timed out */ public ClientInstanceIds clientInstanceIds(Duration timeout); |
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
an IllegalStateException.
In the event that any of the client instance ids cannot be obtained within the timeout, the method throws org.apache.kafka.common.errors.TimeoutException
.
...