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;
}
}