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?的主要内容,如果未能解决你的问题,请参考以下文章

Kafka怒改开源协议,不想云厂商坐收渔翁之利

使用confluent本地安装和使用kafka

Kafka快速入门——Confluent Kafka简介

Kafka快速入门——Confluent Kafka简介

confluent-kafka-go源码分析

Apache Camel Kafka 支持 Confluent 模式注册表