Ошибка фактора репликации при запуске потребителя Kafka

Question

Я вижу следующую ошибку при повторном запуске при запуске потребителя Kafka:

Number of alive brokers '1' does not meet the required replication factor '3' for the offsets topic

Моя конфигурация потребителя Kafka выглядит следующим образом:

    final Properties props = new Properties();
    props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, BOOTSTRAP_SERVERS);
    props.put(ConsumerConfig.GROUP_ID_CONFIG, "verifi");
    props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, Class.forName("org.apache.kafka.common.serialization.StringDeserializer"));
    props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, Class.forName("org.apache.kafka.common.serialization.StringDeserializer"));
    props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");

    final Consumer<String, String> consumer = new KafkaConsumer<>(props);

Как исправить эту ошибку?

Answer 1

Решением было настроить offsets.topic.replication.factor равным 1 в моей конфигурации Kafka. По умолчанию 3.

Я случайно запускаю Kafka в Docker, поэтому для его установки я просто добавил следующую переменную окружения:

KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1