Что обеспечивает Kafka из CAP-теоремы

Kafka обеспечивает AP (Availability и Partition Tolerance) из CAP-теоремы.

• Availability: Kafka гарантирует высокую доступность за счёт репликации данных между брокерами. Даже если часть брокеров недоступна, система продолжает работать.
• Partition Tolerance: Kafka устойчива к разделению сети (network partitions), так как данные реплицируются и распределяются по кластеру.

Consistency (согласованность) в Kafka — eventual (в конечном счёте). Запись считается завершённой после подтверждения от ISR (In-Sync Replicas), но чтение может получить устаревшие данные, пока реплики синхронизируются.

Пример настройки репликации:

// Создание топика с 3 репликами и фактором репликации 2
Properties props = new Properties();
props.put("replication.factor", "2");
AdminClient.create(props)
    .createTopics(Collections.singleton(new NewTopic("my-topic", 3, (short) 2)));