от сообщений? Я знаю 3 способа: пересоздать топик, временно поставить низкий retention, руками поудалять лог-файлы. Как правильно?
Привет У тебя место закончилось или просто нужно не читать уже имеющиеся сообщения? Если сообщения пропустить нужно, то поставь слушателю latest консольной утилитой, если место почистить, то я руками чищу. Может я тоже неправильно делаю, но проблем пока не было из-за этого
Павел, а как вы чистите руками? Иногда сталкиваюсь с проблемой экстренного освобождения места.
Заходишь в папку /data и далее достаточно понятно, куда идти Выбираю файлы, которым допустим день и удаляю
Понятно. А почему автоматической очисткой не пользуетесь? Нет чётких критериев очистки или другие причины?
Пользуемся Просто бывает, когда в течение маленького промежутка времени насыпает много сообщений, которые не очень критично потерять, но соседям на машинке мешает
Лично я просто удаляю топик консольной утилитой. Пока проблем не было. Но я это делаю во время даунтайма. На горячую не знаю что будет.
Она по всем нодам кластера ходит и удаляет?
А вот сейчас вы спросили и я понял, что на кластере я её никогда не выполнял. Но мне кажется, что должна во всём кластере, так как в аргументах там указывается не конкретная нода, а зукипер. Кроме того, команде отрабатает только при наличии исправного лидера топика.
место закончилось или надо почистить чтобы гарантировано удалить все сообщения, чтобы никто физически не мог из никогда прочитать. latest ставить не получится, читаю через assign api
даунтайм тут - это когда выключено приложение, использующее кафку?
А что за автоматическая очистка?
Да. (Точнее, когда клиенты не работают с системой)
Можно в параметрах топика указать условие для автоматического удаления записей. Тогда брокер будет удалять сам.
Обсуждают сегодня