THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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 .
The new class interface org.apache.kafka.streams.ClientInstanceIds is defined as follows:
| Code Block |
|---|
/** * Encapsulates the client instance ids used for metrics collection by * producers, consumers and admin clients used by Kafka Streams. */ public classinterface ClientInstanceIds { /** * Get the client instance id of the admin client * * @return the client instance id */ Uuid adminInstanceId(); /** * Get the client instance ids of the consumers * * @return a map from thread key to client instance id */ Map<String, Uuid> consumerInstanceIds(); /** * Get the client instance ids of the producers * * @return a map from thread key to client instance id */ Map<String, Uuid> producerInstanceIds(); } |
...