0

我的应用程序必须在特定时间或触发时使用来自 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 中公开?

4

1 回答 1

0

ConsumerConfig接受一个MaxPollIntervalMs属性

于 2021-12-22T20:07:12.883 回答