Невозможно установить политику хранения Kafka для сжатия и удаления

Question

Согласно приведенным ниже ссылкам, я должен иметь возможность установить значение retention.policy на "compact,delete".

https://issues.apache.org/jira/browse/KAFKA-4015

https://cwiki.apache.org/confluence/display/KAFKA/KIP-71%3A+Enable+log+compaction+and+deletion+to+co-exist

Однако, когда я пытаюсь изменить политику хранения, запустив:

./kafka-configs.sh --zookeeper $KAFKAZKHOSTS  --entity-type
 topics --alter --add-config cleanup.policy=compact,delete --entity-name topicname

, я получаю следующую ошибку:

requirement failed: Invalid entity config: all configs to be added must be in the format "key=val".

Answer 1

--add-config cleanup.policy=[compact,delete]

Answer 2

Вам необходимо указать значение для политики очистки. Например, если вы хотите установить его на 7 дней, вам следует указать конфигурацию cleanup.policy=compact,delete.retention.ms=604800000.

Теперь полная команда выглядит следующим образом:

./kafka-configs.sh --zookeeper $KAFKAZKHOSTS --entity-type topics --alter --add-config cleanup.policy=compact,delete.retention.ms=604800000 --entity-name topicname

Answer 3

Оказывается, что когда вы впервые создаете тему, вы можете установить политику на сжатие и удаление, но вы не можете изменить ее после факта.

Answer 4

Вы должны заключить конфиг в кавычки: --add-config 'cleanup.policy=compact,delete'