如何在 Spring Kafka Producer 上配置 min.insync.replicas 参数？

Question

在 Java Spring 应用程序中，我将 Producer 配置为使用 Acks，并且还必须设置 min.insync.replicas 参数。

我使用以下方法设置了 Acks：

configProps.put(ProducerConfig.ACKS_CONFIG, kafkaAcks);

但我在ProducerConfig 上找不到min.insync.replicas 属性。查看Kafka Spring Docs 没有找到与min.insync.replicas 相关的属性。

那么，我如何在 Kafka Spring 应用程序上配置 min.insync.replicas？

    @Bean
public KafkaTemplate<String, GenericRecord> kafkaTemplate() {
    return new KafkaTemplate<>(producerFactory());
}

public ProducerFactory<String, GenericRecord> producerFactory() {
    return new DefaultKafkaProducerFactory<>(getProducerGenericRecordConfigurations());
}

private Map<String, Object> getProducerGenericRecordConfigurations() {
    Map<String, Object> configProps = new HashMap<>();
    configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaBootstrapServerUrl);
    configProps.put(KafkaAvroDeserializerConfig.SCHEMA_REGISTRY_URL_CONFIG, schemaRegistryURL);
    configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class);
    configProps.put(ProducerConfig.ACKS_CONFIG, kafkaAcks);
    return configProps;
}

Answer 1

min.insync.replicas 不是生产者配置。这是一个代理/主题设置。

您可以在您的代理的server.properties 文件中为代理设置它。

否则，您可以在创建时或通过更改主题来设置它。