Как пометить сообщение для удаления ключом в Кафке?

Question

Мне нужно отметить сообщение, указанное ключом для удаления, но единственный известный мне скрипт для удаления сообщения - kafka-delete-records.sh.Однако он работает со смещением и удаляет все сообщения до смещения , что мне не подходит.Можно ли удалить из темы только сообщение с указанным смещением или ключ?

Answer 1

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

Вот дополнительная информация о том, как вы можете смотреть на удаление сообщений, используя сжатые темы и надгробные (нулевые) сообщения: https://www.confluent.io/blog/handling-gdpr-log-forget/