kafka confluent .NET 1.8.2 如何在消费者配置中覆盖 max.poll.interval.ms?
Posted
技术标签:
【中文标题】kafka confluent .NET 1.8.2 如何在消费者配置中覆盖 max.poll.interval.ms?【英文标题】:kafka confluent .NET 1.8.2 How to override max.poll.interval.ms in the consumer config? 【发布时间】:2022-01-23 18:42:56 【问题描述】:我的应用程序必须在特定时间或触发时使用来自 kafka 主题的消息。 因此,当我的消费者坐在那里不消费消息时,它会从消费者组中删除。
Application maximum poll interval(300000ms) exceeded by 277ms (adjust max.poll.interval.ms for long-running message processing): leaving group
我的理解是,一旦超过最大轮询间隔,是消费者自己向代理发送请求以从消费者组中删除。此配置设置是否在 Confluent Kafka .NET API 版本 1.8.2 中公开?
【问题讨论】:
【参考方案1】:ConsumerConfig
接受 MaxPollIntervalMs
属性
【讨论】:
以上是关于kafka confluent .NET 1.8.2 如何在消费者配置中覆盖 max.poll.interval.ms?的主要内容,如果未能解决你的问题,请参考以下文章