THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
/**
* @return the clients' assigned instance ids used for metrics collection.
* @throws StreamsNotStartedException Indicates that Kafka Streams is not running.
* @throws StreamsStoppedException Indicates that Kafka Streams is not running.
* @throws TimeoutException Indicates that a request timed out
*/
public ClientInstanceIds clientInstanceIds(Duration timeout); |
...