Как перенести тему кафки в журнал сжатия?

Question

у нас есть тема Kafka, которая cleanup.policy в настоящее время delete .Сообщения, созданные по этой теме, не имеют ключей.Я могу изменить конфигурацию этой темы, и она не будет принимать новые сообщения без ключа, что является разумным и желательным.

Мне интересно, что Кафка собирается делать с этими старыми сообщениями без ключа.Будут ли с ними обращаться так, как будто у них один ключ, или они не будут затронуты новой политикой очистки?

Существуют ли передовые практики для миграции, я не могу найти что-то об этом,Это необычный вариант использования?

Заранее спасибо

Answer 1

Я провел несколько тестов в своем Kafka Cluster и отвечаю на следующие вопросы:

• Сообщения без ключа будут удалены
• Если вы не добавитеновые сообщения, вы можете получить некоторые старые сообщения в разделах, потому что они «в последнем сегменте».Они будут удалены, когда вы добавите новые сообщения

Я думаю, что я представлю новую уплотненную тему и опубликую свои данные в новой.Это заставляет всех потребителей использовать новую тему, но в моем случае это нормально.

Удачи мне в будущем