Package org.apache.kafka.streams

Interface ClientInstanceIds

public interface ClientInstanceIds
Encapsulates the client instance id used for metrics collection by producers, consumers, and the admin client used by Kafka Streams.

  • Method Details

    • adminInstanceId

      Uuid adminInstanceId()
      Returns the client instance id of the admin client.
      Returns:
      the client instance id of the admin client
      Throws:
      IllegalStateException - If telemetry is disabled on the admin client.

    • consumerInstanceIds

      Map<String,Uuid> consumerInstanceIds()
      Returns the client instance id of the consumers.
      Returns:
      a map from thread key to client instance id

    • producerInstanceIds

      Map<String,Uuid> producerInstanceIds()
      Returns the client instance id of the producers.
      Returns:
      a map from thread key to client instance id