我嘗試通過以下兩種方式定義 request.timeout.ms 屬性：-
應用程式屬性
1. spring.kafka.consumer.request.timeout.ms=60000
2. spring.kafka.consumer.request-timeout-ms=60000
但是，當我啟動消費者服務時，我可以看到它并沒有覆寫價值
我是否正確定義了財產？？？或者需要在某處添加覆寫屬性？？？
uj5u.com熱心網友回復：
請參閱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 指定具有高、中或低重要性的屬性。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
uj5u.com熱心網友回復：
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.
轉載請註明出處，本文鏈接：https://www.uj5u.com/gongcheng/370027.html
上一篇：CrudRepository<TourClaimModel,Integer>型別中的save(S)方法不適用于引數(List<TourClaimModel>)