我尝试定义request.timeout.ms属性在以下2种方式:-
应用.属性
1. spring.kafka.consumer.request.timeout.ms=60000
2. spring.kafka.consumer.request-timeout-ms=60000
字符串
但是,当我启动消费者服务时,我可以看到它没有覆盖值x1c 0d1x
我是否正确地定义了属性?或者需要在某处添加重写属性?
我尝试定义request.timeout.ms属性在以下2种方式:-
应用.属性
1. spring.kafka.consumer.request.timeout.ms=60000
2. spring.kafka.consumer.request-timeout-ms=60000
字符串
但是,当我启动消费者服务时,我可以看到它没有覆盖值x1c 0d1x
我是否正确地定义了属性?或者需要在某处添加重写属性?
3条答案
按热度按时间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类使用。如果您希望使用不直接支持的其他属性配置生产者或消费者,请使用以下属性:
字符串
5f0d552i2#
第一个月
对于ConsumerProperties,您可以在这里看到:https://docs.spring.io/spring-boot/docs/current/api/org/springframework/boot/autoconfigure/kafka/KafkaProperties.Consumer.html
如果您可以在上面的类中找到任何Kafka消费者属性,请将其放在
properties
中。gc0ot86w3#
只需要比前面的两个问题更具体一点。改变
request.timeout.ms
的方法是:字符串
并不是说前面的解释是错误的,但它们并没有直接解决这个问题。请注意其中一个问题中建议的 admin 而不是 consumer 的部分。Admin是在OP要求启动应用程序时显示的部分。