如何在spring Kafka属性文件中定义Kafkarequest.timeout.ms属性

xiozqbni  于 5个月前  发布在  Apache
关注(0)|答案(3)|浏览(64)

我尝试定义request.timeout.ms属性在以下2种方式:-

应用.属性

1. spring.kafka.consumer.request.timeout.ms=60000 
2. spring.kafka.consumer.request-timeout-ms=60000

字符串
但是,当我启动消费者服务时,我可以看到它没有覆盖值x1c 0d1x
我是否正确地定义了属性?或者需要在某处添加重写属性?

nzkunb0c

nzkunb0c1#

请访问https://docs.spring.io/spring-boot/docs/current/reference/html/messaging.html#messaging.kafka.additional-properties
自动配置支持的属性显示在application-properties. html中。请注意,在大多数情况下,这些属性(带连字符或驼峰大小写)直接Map到Apache Kafka点属性。有关详细信息,请参阅Apache Kafka文档。
这些属性中的前几个适用于所有组件(生产者、消费者、管理员和流),但如果您希望使用不同的值,则可以在组件级别指定。Apache Kafka指定重要性为HIGH、MEDIUM或LOW的属性。Sping Boot 自动配置支持所有HIGH重要性属性,一些选定的MEDIUM和LOW属性,以及任何没有默认值的属性。
只有Kafka支持的属性的一个子集可以直接通过KafkaProperties类使用。如果您希望使用不直接支持的其他属性配置生产者或消费者,请使用以下属性:

spring.kafka.properties[prop.one]=first
spring.kafka.admin.properties[prop.two]=second
spring.kafka.consumer.properties[prop.three]=third
spring.kafka.producer.properties[prop.four]=fourth
spring.kafka.streams.properties[prop.five]=fifth

字符串

5f0d552i

5f0d552i2#

第一个月
对于ConsumerProperties,您可以在这里看到:https://docs.spring.io/spring-boot/docs/current/api/org/springframework/boot/autoconfigure/kafka/KafkaProperties.Consumer.html
如果您可以在上面的类中找到任何Kafka消费者属性,请将其放在properties中。

gc0ot86w

gc0ot86w3#

只需要比前面的两个问题更具体一点。改变request.timeout.ms的方法是:

spring.kafka.admin.properties[request.timeout.ms]=1000

字符串
并不是说前面的解释是错误的,但它们并没有直接解决这个问题。请注意其中一个问题中建议的 admin 而不是 consumer 的部分。Admin是在OP要求启动应用程序时显示的部分。

相关问题