Chcemy zmienić godziny zatrzymania Kafki do 1 godziny

kafka-configs.sh --alter --zookeeper localhost:2181  --entity-type topics  --entity-name topic_test --add-config retention.hours=1
Error while executing config command Unknown topic config name: retention.hours
org.apache.kafka.common.errors.InvalidConfigurationException: Unknown topic config name: retention.hours

Potem próbujemy

kafka-configs.sh --alter --zookeeper localhost:2181  --entity-type topics  --entity-name topic_test --add-config retention.ms=3600000
Completed Updating config for entity: topic 'test_topic'.

mój równanie jest

Dawka retention.ms jest taka sama jak retention.hours, ale w milisekundach?

Celem jest oczyszczenie plików Kafka danych po 1 godzinie

Ale kafka-configs.sh nie akceptuje retention.hours=1, więc zmieniamy go na retention.ms=3600000

jak rozumiem Czas retencji jest kontrolowany przez szeroki klaster jako:

log.retention.ms
log.retention.minutes
log.retention.hours  

więc te właściwości konfiguracyjne są z wyższe, aby obniżyć Ale jak wyjaśniłem Kafka CLI COT, użyj retencji.Hours, więc jest to powód, dla którego używam retention.ms=3600000

Odniesienie -

https://jaceklaskowski.gitbooks.io/apache-kafka/content/kafka-log-clanup-police.html#log-retents. https://docs.clouera.com/hdpdocuments/HDP3/HDP-3.1.5/Installing-configuring-kafka/content/log_settings.html.

0
jessica 28 lipiec 2020, 12:12

1 odpowiedź

Najlepsza odpowiedź

retention.hours nie istnieje jako Temat Config

1
OneCricketeer 28 lipiec 2020, 21:24