Search code examples
apache-kafkakafka-consumer-api

Kafka consumer unique cluster ID?


Does a Kafka cluster have some unique ID that I can get programmatically out of a Kafka consumer? I checked for message headers, but it looks like there's no metadata in them by default and I don't see any methods in a KafkaConsumer or ConsumerRecord for retrieving such a value either.


Solution

  • You can use AdminClient to get the cluster id, but generally, there's no reason for clients to know internal server information