их каких-то нет, в чем может быть дело?
Записи из топиков фактически не удаляются, до тех пор пока не удалится определлный сегмент. Посмотрите segment.retention.ms (вроде как то так называется)
что есть действие "удаления записи"? можно пример команды?
kafka-delete-records.sh --bootstrap-server kafka:9092 --offset-json-file и путь до файла
и файл примерно такой {'partitions': [{'topic': 'мой топик', 'partition': 0, 'offset': -1}, ...]
нужно еще глянуть частоту сброса сегмента мб нагрузка маленькая и сегмент просто закрыться не может)
я думал политика такая же как с linger.ms или batch.size. что наполнилось быстрее то и срабатывает
Разобрался. Вот в чем была проблема.
Обсуждают сегодня