Чтобы изменить параметры кластера Kafka, например, количество реплик для топика, нужно использовать команду kafka-topics.sh с опцией --alter. Например, чтобы изменить количество реплик, выполняют:

kafka-topics.sh --zookeeper <zookeeper_host>:<port> --alter --topic <topic_name> --replication-factor <new_replication_factor>

Однако стоит учитывать, что изменение replication-factor не всегда тривиально и требует, чтобы в кластере было достаточно брокеров для размещения новых реплик. При увеличении количества реплик Kafka начнёт создавать новые копии партиций на других брокерах.

Что происходит с клиентами:

Клиенты, которые читают из топика, не требуют перезапуска — они автоматически получают обновлённую метаинформацию о партициях и репликах при следующем обновлении metadata.
Продюсеры также автоматически обновляют информацию о партициях и репликах.

Таким образом, изменение параметров топика происходит на уровне кластера, а клиенты адаптируются динамически без необходимости ручного вмешательства.

Важно: в новых версиях Kafka рекомендуется использовать Kafka Admin API или kafka-topics с bootstrap-server вместо zookeeper, так как Zookeeper постепенно выводится из эксплуатации.

Как менять параметры кластера Kafka (например, количество реплик для топика) и что происходит дальше с клиентами?