如何在Spring Cloud Stream中启用Kafka消费者静态成员？

cwtwac6a 于 2023-05-16 发布在 Spring

关注(0)|答案(1)|浏览(194)

spring Kafka的官方文档说，我们可以在设置并发大于1后配置静态成员。但是，当我检查消费者配置时，我发现group.instance.id被设置为null。
从版本2.3.8、2.4.6开始，ConcurrentMessageListenerContainer现在在并发大于1时支持静态成员资格。group.instance.id的后缀是-n，n从1开始。这与增加的www.example.com一起session.timeout.ms可以用于减少重新平衡事件，例如，当应用程序示例重新启动时。
有人知道如何在Spring Cloud Stream应用程序中配置Kafka静态成员吗？
Sping Boot 版本：2.6.2
Kafka集群版本：2.6.0
Spring Kafka版本：2.8.0
属性摘要：

spring:
 cloud:
  stream:
   default:
    consumer:
     concurrency: 20

spring

来源：https://stackoverflow.com/questions/76235310/how-to-enable-kafka-consumer-static-membership-in-spring-cloud-stream

1条答案

按热度按时间

b4lqfgs41#

设置spring.cloud.stream.kafka.bindings.<channelName>.consumer.properties.group.instance.id
Spring将为并发设置创建的每个消费者追加-n。

赞(0）回复(0）举报 2023-05-16

我来回答

如何在Spring Cloud Stream中启用Kafka消费者静态成员？

1条答案

相关问题

热门标签

最新问答