Java, Wie bekomme ich die Anzahl der Nachrichten in einem Thema in Apache Kafka?

Ich benutze Apache Kafka für Messaging. Ich habe den Producer und Consumer in Java implementiert. Wie kann die Anzahl der Nachrichten in einem Thema ermittelt werden?