Как динамически обновить период хранения смещения - PullRequest
Новая
       13

Как динамически обновить период хранения смещения

0 голосов
/ 14 марта 2019

Мы используем Kafka 1.1x, и текущее значение по умолчанию для свойства offsets.retention.minutes broker установлено на 7 дней (т.е. 1440).

В связи с изменением требований к хранению нам пришлось увеличить нашу политику хранения журналов.до 6 месяцев.Мы хотели бы увеличить offsets.retention.minutes до 262800.

Мы попытались динамически обновить свойство с помощью следующей команды, но оно не работает, поскольку offsets.retention.minutes не является динамическим свойством.

bin/kafka-configs.sh --zookeeper _host_:_port_ --entity-type brokers --entity-name 0 --alter --add-config offsets.retention.minutes=262800

Error while executing config command requirement failed: Unknown Dynamic Configuration 'retention.minutes'.
java.lang.IllegalArgumentException: requirement failed: Unknown Dynamic Configuration 'retention.minutes'.
        at scala.Predef$.require(Predef.scala:224)
        at kafka.server.DynamicConfig$$anonfun$kafka$server$DynamicConfig$$validate$1.apply(DynamicConfig.scala:101)
        at kafka.server.DynamicConfig$$anonfun$kafka$server$DynamicConfig$$validate$1.apply(DynamicConfig.scala:100)
        at scala.collection.Iterator$class.foreach(Iterator.scala:893)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1336)
        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)

Есть ли способ обновить свойство offsets.retention.minutes без перезапуска посредников?

Спасибо!

...