У випадках, коли потрібно видалити повідомлення з Kafka Topic, але блокується можливість видалення топіку через налаштування Kafka, існує спосіб полегшити процес. Можна встановити налаштування, щоб Kafka автоматично видаляла дані, якщо вказано видалення повідомлень, а не їх “архівування”.
Якщо ви використовуєте, наприклад, Strimzi Operator, для виконання цієї операції необхідно перейти до будь-якого брокера та виконати наступну команду:
/usr/bin/kafka-configs --bootstrap-server <bootstrap_service>:9092 --entity-type topics --entity-name <your_topic> --alter --add-config retention.ms=<retention_in_ms>де:
bootstrap_service – сервіс брокеру, чи ендпоінт, якщо кластер не у kubernetes
your_topic – імʼя топіку, де запроваджуємо зміни
retention_in_ms – час у мілісекундах
Будь першим хто прокоментує