Я пытаюсь запустить несколько брокеров kafka. Есть файл с именем server.properties и поле «log.retention.hours», которое установлено на 168 в моем файле server.properties. Теперь, если я изменю файл свойств брокеров kafka и установлю разные значения «log.retention.hours» в каждом файле свойств, то как он будет действовать в распределенной среде. Я хочу сказать, что брокеры kafka в одном кластере реплицируют все разделы, что произойдет, если log.retention.hours в брокере-1 отличается от log.retention.hours в брокере-2. Как будет происходить репликация разделов. будут ли данные, которые были удалены на сервере 1, будут снова реплицированы с других брокеров (при условии, что (server-1 log.retention.period) ‹(server-2 log.retention.period)).
kafka log.retention.hours несоответствие в нескольких брокерах
Ответы (1)
Одно из основных предположений при разработке Kafka заключается в том, что брокеры в кластере, за очень немногими исключениями (например, порт), будут иметь такую же конфигурацию, как описано в этом Предложении по улучшению Kafka. В результате следует избегать сценария с несовместимыми конфигурациями, который вы описали в своем вопросе.
person
Chris Gerken
schedule
04.06.2015
