我们如何在 spring kafka 属性文件中定义 kafka request.timeout.ms 属性答案

【问题标题】：How do we define kafka request.timeout.ms property in spring kafka properties file我们如何在 spring kafka 属性文件中定义 kafka request.timeout.ms 属性
【发布时间】：2022-01-06 00:56:00
【问题描述】：

我尝试通过以下两种方式定义 request.timeout.ms 属性：-

application.properties

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

但是，当我启动消费者服务时，我可以看到它并没有覆盖价值

我是否正确定义了财产？？？还是需要在某处添加覆盖属性？？？

【问题讨论】：

标签： spring apache-kafka spring-kafka

【解决方案1】：

spring.kafka.consumer.properties[request.timeout.ms]=60000

对于 ConsumerProperties，您可以在此处查看：https://docs.spring.io/spring-boot/docs/current/api/org/springframework/boot/autoconfigure/kafka/KafkaProperties.Consumer.html

如果您可以在上述类中找到任何 Kafka 消费者属性，请将其放入 properties。

【讨论】：

【解决方案2】：

见https://docs.spring.io/spring-boot/docs/current/reference/html/messaging.html#messaging.kafka.additional-properties

自动配置支持的属性显示在 application-properties.html 中。请注意，在大多数情况下，这些属性（连字符或驼峰式）直接映射到 Apache Kafka 点属性。有关详细信息，请参阅 Apache Kafka 文档。

前几个属性适用于所有组件（生产者、消费者、管理员和流），但如果您希望使用不同的值，可以在组件级别指定。 Apache Kafka 指定具有 HIGH、MEDIUM 或 LOW 重要性的属性。 Spring 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

【讨论】：