java - Kafka Streams - 偏移量提交失败。请求超时

标签 java apache-kafka apache-kafka-streams

我正在获取

Offset commit failed on partition app-KSTREAM-MAP-0000000017-repartition-2 at offset 2768614: The request timed out.

我已经将请求超时增加到 1 分钟,但没有帮助。我正在使用的版本:

  • spring-kafka:2.1.12.RELEASE
  • kafka-clients、kafka-streams:2.1.1
  • kafka_2.11:2.1.1

最佳答案

尝试减小批量大小ConsumerConfig.MAX_POLL_RECORDS_CONFIG

还要看看调整这些

  • ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG
  • ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG

关于java - Kafka Streams - 偏移量提交失败。请求超时,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56059298/

相关文章:

go - 使用 Shopify Sarama 的 Kafka 错误处理

apache-kafka - Streamparse wordcount 示例

java - 用于添加全局存储的 Kafka 流用例

apache-kafka - 如何将 Kafka 消息从一个主题发送到另一个主题?

scala - Akka Stream Kafka 与 Kafka Streams

java - 使用初始化程序在构造函数 VS 中完成工作

java - 在 Spring 项目中实现 JSR-303 注释

java - 查找重复的 XML 元素名称(带变量的 xPath)

Java - 如何逐字节读取 .dat 文件

apache-kafka - 如何从 KTable 中获取排序后的 KeyValueStore?