Конфигурация Kafka: в чем разница между параметром «cleanup.policy» и параметром «log.cleanup.policy»?

#apache-kafka

Вопрос:

Есть два параметра для настройки политики очистки Kafka.

  • cleanup.policy
  • log.cleanup.policy

В чем разница между ними?

введите описание изображения здесь

Ссылка

Платформа Confluent: Тематические конфигурации

Ответ №1:

Как говорится, «Свойство сервера по умолчанию» — log.cleanup.policy это параметр брокера и используется по умолчанию для всех разделов

cleanup.policy используется ли параметр темы для определенной темы

Документы также неверны (по крайней мере, таблица). Допустимые значения ['compact', 'delete', 'compact,delete'] KIP-71

Комментарии:

1. Если у нас есть два брокера и мы обращаемся log.cleanup.policy к брокеру A, что произойдет с брокером B?

2. Я бы предположил, что когда-либо является контроллером. Но я не уверен, потому что я никогда не настраивал кластер неправильно, как это