如何在 application.yml 中设置 max.incremental.fetch.session.cache.slots答案

【问题标题】：How can I set max.incremental.fetch.session.cache.slots in application.yml如何在 application.yml 中设置 max.incremental.fetch.session.cache.slots
【发布时间】：2021-11-02 01:56:52
【问题描述】：

我正在使用 Kafka + Spring，我的疑问是如何在 application.yml

中设置此配置 max.incremental.fetch.session.cache.slots

因为我一直在日志中收到这条消息：

[Consumer clientId=client-valid-0, groupId=valid-group] Node 11103 was unable to process the fetch request with (sessionId=1130053497, epoch=425): FETCH_SESSION_ID_NOT_FOUND.

【问题讨论】：

标签： spring-boot apache-kafka spring-kafka

【解决方案1】：

请参阅 Spring Boot 文档：

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

只有 Kafka 支持的属性的一个子集可以直接通过 KafkaProperties 类获得。如果您希望使用不直接支持的其他属性配置生产者或消费者，请使用以下属性：

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

这将常见的prop.one Kafka 属性设置为第一（适用于生产者、消费者和管理员），prop.two 管理属性设置为第二，prop.three 消费者属性设置为第三，prop.four 生产者属性设置为第四和prop.five 流属性到第五。

【讨论】：