Что знаешь про Insync replica в Kafka

Insync replica (ISR) в Kafka — это набор реплик партиции, которые полностью синхронизированы с лидером. Они актуальны и готовы заменить лидера в случае его отказа.

Как работает:

• Лидер (leader) обрабатывает все запросы на запись/чтение.
• Реплики (followers) асинхронно копируют данные с лидера.
• Если реплика успевает синхронизироваться, она попадает в ISR.

Пример проверки ISR через CLI:

kafka-topics --describe --bootstrap-server localhost:9092 --topic test-topic

Вывод включает список ISR для каждой партиции.

Важные моменты:

• Если ISR пуст, партиция становится недоступной для записи.
• Настройка min.insync.replicas определяет минимальное количество ISR для работы.
• При выходе лидера из строя Kafka выбирает нового из ISR.

Пример кода для проверки ISR через confluent-kafka-python:

from confluent_kafka.admin import AdminClient

admin = AdminClient({'bootstrap.servers': 'localhost:9092'})
metadata = admin.list_topics()
topic = metadata.topics['test-topic']
for partition in topic.partitions.values():
    print(f"Partition {partition.id}: ISR={partition.isr}")