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?
我的应用程序必须在特定时间或触发时使用来自 kafka 主题的消息。
因此,当我的消费者坐在那里而不消费消息时,它会从消费者组中删除。
Application maximum poll interval(300000ms) exceeded by 277ms (adjust max.poll.interval.ms for long-running message processing): leaving group
我的理解是,一旦超过最大轮询间隔,是消费者自己向broker发送请求,要求从消费者组中移除。此配置设置是否在 Confluent Kafka .NET API 1.8.2 版中公开?
ConsumerConfig
接受 MaxPollIntervalMs
属性
我的应用程序必须在特定时间或触发时使用来自 kafka 主题的消息。 因此,当我的消费者坐在那里而不消费消息时,它会从消费者组中删除。
Application maximum poll interval(300000ms) exceeded by 277ms (adjust max.poll.interval.ms for long-running message processing): leaving group
我的理解是,一旦超过最大轮询间隔,是消费者自己向broker发送请求,要求从消费者组中移除。此配置设置是否在 Confluent Kafka .NET API 1.8.2 版中公开?
ConsumerConfig
接受 MaxPollIntervalMs
属性