Spring для Apache Kafka: конфигурация нераспознанного производителя - delivery.timeout.ms - PullRequest
Новая
       34

Spring для Apache Kafka: конфигурация нераспознанного производителя - delivery.timeout.ms

0 голосов
/ 03 октября 2019

У меня есть приложение весенней загрузки, в котором Spring для Apache Kafka используется для отправки сообщений в разделы кластера kafka. Я автоматически связал свойство для delivery.timeout.ms , и после запуска приложения и настройки производителя журналы приложений показывают, что значение свойства не было установлено, и выдает предупреждение: "WARN [task-scheduler-1] org.apache.kafka.clients.producer.ProducerConfig [] --- The configuration 'delivery.timeout.ms' was supplied but isn't a known config"

Я проверил свой POM и подтвердил, что использую следующие две зависимости: 

<dependency>
            <groupId>org.springframework.kafka</groupId>
            <artifactId>spring-kafka</artifactId>
            <version>2.2.2.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>2.1.0</version>
        </dependency>

Я также подтвердил, что свойство существовало в версии 2.1. 0: https://kafka.apache.org/21/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html

Я вижу сообщения с похожим предупреждением для других свойств, в которых упоминается, что их можно игнорировать;однако в моем приложении наблюдается нежелательное поведение, которое можно исправить, установив это свойство на основе его описания.

1 Ответ

0 голосов
/ 03 октября 2019

Похоже, переопределение вашей версии kafka-клиентов не работает. Я только что проверил его, и он работал нормально (с spring-kafka 2.2.9 и клиентами 2.1.1): 

ProducerConfig values: 
    acks = 1
    batch.size = 16384
    bootstrap.servers = [localhost:9092]
    buffer.memory = 33554432
    client.dns.lookup = default
    client.id = 
    compression.type = none
    connections.max.idle.ms = 540000
    delivery.timeout.ms = 123456
    enable.idempotence = false
    ...

Попробуйте выполнить инструкции в справочном руководстве Spring for Apache Kafka для переопределения всех клиентских библиотек kafka.

...