Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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 .

...