Определите размер данных в каждом разделе в теме кафки

Question

Просто хотелось узнать, как определить, сколько каждого тематического раздела в Kafka занимает место. Используя "kafka-consumer-groups.sh", мы можем определить число смещений, но я хотел знать, сколько места в данных занятокаждый раздел занимает ..

Answer 1

Используя AdminClient, вы можете найти размер разделов (для каждой реплики), используя describeReplicaLogDirs().

Как уже упоминалось, это для каждой реплики, поэтому, если разделы имеют несколько реплик, вы можете либо запросить их все, либо запросить только лидера, в зависимости от того, как вы хотите посчитать размер на диске.