如何在spring boot kafka项目中重写属性

Question

我如何添加/覆盖max.poll.interval.ms和max.poll.records在我的. yml文件在Spring启动Kafka微服务项目

我试过了，但没用

Kafka:
 consumer: 
  max-poll-records: 200
  max-poll-interval-ms: 600000ms

Answer 1

必须是这样的：

spring:
  kafka:
    consumer:
      max-poll-records: 200
      properties:
        max.poll.interval.ms: 600000

请参阅Spring Boot文档：https://docs.spring.io/spring-boot/docs/current/reference/htmlsingle/#messaging.kafka.additional-性质

max.poll.interval.ms没有公开到KafkaProperties中，因此必须在该属性部分下使用它的原始名称。注意：您也不能使用ms，因为Temporal转换仅对公开的属性进行。