Удалить пустые темы из Кафки

Question

Я хотел бы удалить все пустые темы Кафки (периодически из cron). Мне не удалось найти одну команду для этого в документации? Переходя к написанию сценариев:

Сначала я установил delete.topic.enable=true

Проблема в том, чтобы найти текущее количество сообщений в теме. Я могу показать общее количество сообщений с:

$KAFKA_DIR/bin/kafka-run-class.sh kafka.tools.GetOffsetShell \
  --broker-list $KAFKA_BOOTSTRAP --topic $TOPIC --time -1

Однако сюда входят сообщения, срок действия которых истек? Как найти фактический текущий счет в теме, если не считать потребителя?

Answer 1

kafka.tools.GetOffsetShell будет считать смещения вместо фактических сообщений.

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