Kafka consumer client ID


What's inside this article ⌄
  • How to get Kafka consumer id
  • Kafka client id retrieval
  • Get consumer client id Kafka
  • Kafka consumer identify client

If you want to read clientid from Kafka Consumer, you may use this method:

private String readConsumerClientId(KafkaConsumer<String, String> consumer) {
    try {
        Method method = consumer.getClass().getDeclaredMethod("getClientId");
        method.setAccessible(true);
        return (String) method.invoke(consumer);
    } catch (Exception ex) {
        ex.printStackTrace();
        return null;
    }
}