Настройка log.retentions.hours для брокера в Кафке 0.10.2.x

Question

Я пытаюсь установить log.retenton.hours для конфигурации уровня брокера для kafka 0.10.2x. Но я получаю эту ошибку для команды ниже.

kafka-configs.sh  --zookeeper zookeeper:2181 --entity-type brokers --entity-name 0 --alter --add-config log.retention.hours=-1

Error while executing config command requirement failed: Unknown Dynamic Configuration 'log.retention.hours'.
java.lang.IllegalArgumentException: requirement failed: Unknown Dynamic Configuration 'log.retention.hours'.
    at scala.Predef$.require(Predef.scala:277)
    at kafka.server.DynamicConfig$.$anonfun$validate$1(DynamicConfig.scala:101)
    at kafka.server.DynamicConfig$.$anonfun$validate$1$adapted(DynamicConfig.scala:100)
    at scala.collection.Iterator.foreach(Iterator.scala:929)
    at scala.collection.Iterator.foreach$(Iterator.scala:929)
    at scala.collection.AbstractIterator.foreach(Iterator.scala:1406)
    at kafka.server.DynamicConfig$.kafka$server$DynamicConfig$$validate(DynamicConfig.scala:100)
    at kafka.server.DynamicConfig$Broker$.validate(DynamicConfig.scala:59)
    at kafka.admin.AdminUtils$.changeBrokerConfig(AdminUtils.scala:555)
    at kafka.admin.ConfigCommand$.alterConfig(ConfigCommand.scala:105)
    at kafka.admin.ConfigCommand$.main(ConfigCommand.scala:68)
    at kafka.admin.ConfigCommand.main(ConfigCommand.scala)

Answer 1

log.retention.hours - это свойство только для чтения на уровне посредника, поэтому его нельзя изменить с помощью kafka-config.sh динамически.

Измените его в server.properties и перезапустите посредников.

Вот подробные сведения о конфигурации только для чтения или динамической конфигурации брокера.https://kafka.apache.org/documentation/#dynamicbrokerconfigs

Answer 2

Как говорит ошибка, это свойство не является динамическим (не может быть изменено во время работы посредника)

Кроме того, эта функция не должна быть возможной в вашей версии

Начиная с версии Kafka 1.1, некоторые конфигурации брокера могут обновляться без перезапуска брокера

Вы можете установить срок хранения для уровня темы, в противном случае вам необходимо отредактировать файл server.properties каждого брокера и корректно перезагрузить их

Я уверен, что у вас есть веская причина для «отключения» хранения, но я бы посоветовал сначала попробовать сжатые темы