属性文件中 kafka 生产者的映射配置失败

Question

我正在尝试将生产者配置添加到我的项目中，在下面使用 Spring Integration 和 Kafka。

由于没找到放的地方，我想我应该把它添加到我的application.properties下：

spring.cloud.stream.kafka.bindings.output.producer.configuration

但是，我无法使用以下任何格式编译代码：

spring.cloud.stream.kafka.bindings.output.producer.configuration=request.timeout.ms=100000
spring.cloud.stream.kafka.bindings.output.producer.configuration={'request.timeout.ms':'100000'}
spring.cloud.stream.kafka.bindings.output.producer.configuration={"request.timeout.ms":"100000"}
spring.cloud.stream.kafka.bindings.output.producer.configuration=request.timeout.ms:100000

我总是收到这个错误：

Binding to target org.springframework.cloud.stream.binder.kafka.KafkaExtendedBindingProperties@104392ba failed:

    Property: spring.cloud.stream.kafka.bindings[output].producer.configuration
    Value: request.timeout.ms:100000
    Reason: Failed to convert property value of type 'java.lang.String' to required type 'java.util.Map' for property 'bindings[output].producer.configuration'; nested exception is java.lang.IllegalStateException: Cannot convert value of type 'java.lang.String' to required type 'java.util.Map' for property 'configuration': no matching editors or conversion strategy found

知道如何向生产者实施此配置吗？

Answer 1

你应该按以下方式使用：

spring.cloud.stream.kafka.bindings.output.producer.configuration.request.timeout.ms=100000

配置名称后应加
spring.cloud.stream.kafka.bindings.<binding name>.producer.configuration前缀

这样，你可以添加任意数量的配置。