В Apache Kafka сообщения не удаляются сразу после публикации, так как Kafka спроектирована как распределённый журнал событий с возможностью хранения истории сообщений.

Удаление сообщений происходит по следующим принципам:

Сообщения удаляются автоматически на основе настроек хранения (retention policy), например, по времени (retention.ms) или по размеру (retention.bytes) топика.
Можно настроить удаление сообщений с помощью политики compacted topics, где сохраняются только последние значения по ключу.

Полностью удалить отдельное сообщение сразу после публикации нельзя, так как Kafka не поддерживает удаление сообщений по ID. Можно только настроить период хранения, после которого сообщения будут удалены.

Если требуется "удалить" сообщение, обычно используют:

Настройку короткого времени хранения для топика.
Отправку специальных сообщений с null-значением (tombstone) для compacted топиков, чтобы пометить запись как удалённую.

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

Можно ли полностью удалить сообщения из Kafka после их публикации?