В apache kafka, как мы можем удалить содержимое _schemas topi c без удаления topi c?

Question

In apache kafka, есть ли опция удаления содержимого _schemas topi c без удаления topi c и без изменения срока хранения на 1 se c?

Answer 1

В ответ на ответ @cricket_007, внутренние темы Kafka __consumer_offsets и _schemas имеют компактную политику очистки по умолчанию.

Если вы хотите изменить конфигурацию просто для удаления, вы можете использовать ./kafka-topics.sh --zookeeper <host>:2181 --topic _schemas --alter --config cleanup.policy=delete

Несмотря на то, что обе политики компактны, рекомендуется удалить.

Answer 2

Ну, сама топи c установлена ​​на cleanup.policy=compact, поэтому сохранение не применяется.

Если вы хотите пустую топи c, вам просто нужно перезагрузить Реестр с другим kafkastore.topic, чтобы создать новый

В противном случае, установите cleanup.policy=compact,delete, затем что-то вроде log.retention.ms=100, очистит топи c