小编esq*_*rer的帖子

超过 max.poll.interval.ms 后,Kafka 消费者卡住了

当消费者在 5 分钟内(默认值 max.poll.interval.ms 300000ms)没有收到消息时,消费者会停止而不退出程序。消费者进程挂起,不再消费任何消息。

记录以下错误消息

MAXPOLL|rdkafka#consumer-1| [thrd:main]: Application maximum poll interval (300000ms) exceeded by 255ms (adjust max.poll.interval.ms for long-running message processing): leaving group
Run Code Online (Sandbox Code Playgroud)

我看到在 confluent-kafka-go 中ErrMaxPollExceeded定义了它,但无法找到它在哪里被提出。

如果出现任何此类错误,为什么程序不退出?

  • 卡夫卡 v1.1.0
  • librdkafka v1.0.0
  • confluent-kafka-go(主)

用于 kafka.Consumer 的配置

{
    "bootstrap.servers":    "private.kafka.host",
    "group.id":             "foo.bar",
    "auto.offset.reset":    "earliest",
    "enable.auto.commit":   false,
}
Run Code Online (Sandbox Code Playgroud)

go apache-kafka librdkafka confluent-platform

10
推荐指数
1
解决办法
3941
查看次数

Neo4j Docker Image的配置文件

我在Mac OSX中安装了neo4j-3.0作为docker镜像.我在哪里可以找到neo4j的配置文件?

macos neo4j docker

7
推荐指数
1
解决办法
2691
查看次数