文章/答案/技术大牛

发布

社区首页 >问答首页 >Apache & Kafka FETCH_SESSION_ID_NOT_FOUND信息日志

问Apache & Kafka FETCH_SESSION_ID_NOT_FOUND信息日志
EN

Stack Overflow用户

提问于 2020-05-04 08:28:25

回答 1查看 2K关注 0票数 2

我们的Flink应用程序有一个Kafka数据源。

应用程序以32种并行方式运行。

当我查看日志时，我看到了很多关于FETCH_SESSION_ID_NOT_FOUND的声明。

2020-05-04 11:04:47,753 INFO  org.apache.kafka.clients.FetchSessionHandler                  - [Consumer clientId=consumer-81, groupId=sampleGroup]
Node 26 was unable to process the fetch request with (sessionId=439766827, epoch=42): FETCH_SESSION_ID_NOT_FOUND.
2020-05-04 11:04:48,230 INFO  org.apache.kafka.clients.FetchSessionHandler                  - [Consumer clientId=consumer-78, groupId=sampleGroup]
Node 28 was unable to process the fetch request with (sessionId=281654250, epoch=42): FETCH_SESSION_ID_NOT_FOUND.

这些日志语句意味着什么？

可能的负面影响是什么？

否:我没有使用Apache的经验

谢谢..

apache-kafka

apache-flink

flink-streaming

回答 1

Stack Overflow用户

回答已采纳

发布于 2020-05-04 09:58:40

这可能有几个原因，但最常见的原因是代理上的FetchSession缓存已满。

默认情况下，代理缓存最多可达1000个FetchSessions (通过max.incremental.fetch.session.cache.slots配置)。当这个数据被填满时，代理会删除缓存条目。如果客户端缓存条目消失，它将收到FETCH_SESSION_ID_NOT_FOUND错误。

此错误并不致命，使用者应自动发送新的完整FetchRequest并继续工作。

您可以使用FetchSession度量来检查kafka.server:type=FetchSessionCache,name=NumIncrementalFetchSessions缓存的大小。

票数 3

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/61588029

复制

相似问题

问Apache & Kafka FETCH_SESSION_ID_NOT_FOUND信息日志
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Apache & Kafka FETCH_SESSION_ID_NOT_FOUND信息日志EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Apache & Kafka FETCH_SESSION_ID_NOT_FOUND信息日志
EN