Несколько смещений.topic.replication.factor в кафка-кластере?

Question

Я знаю, что параметру offsets.topic.replication.factor задается server.properties для брокера.

Могу ли я создать одну из тем как:

offsets.topic.replication.factor = 1

, а другую как:

offsets.topic.replication.factor = 2

в kafka-кластере?

У меня 3 zookeper, 3 брокера и мой коэффициент репликации кластера = 2.

Answer 1

Для всего кластера Kafka существует только одна тема смещения потребителя, которая создается автоматически при запуске кластера.

Настройка должна быть одинаковой для каждого посредника, и offsets.topic.replication.factor нельзя установить на уровне темы

Этот параметр отличается от default.replication.factor, и вам действительно следует отключить автоматическую темусоздание и указание этих факторов репликации при создании тем вручную