我不断收到 FETCH_SESSION_ID_NOT_FOUND。我不确定为什么会这样。任何人都可以请我在这里问题是什么以及对消费者和经纪人的影响是什么。
卡夫卡服务器日志:
INFO [2019-10-18 12:09:00,709] [ReplicaFetcherThread-1-8][] org.apache.kafka.clients.FetchSessionHandler - [ReplicaFetcher replicaId=6, leaderId=8, fetcherId=1] Node 8 was unable to process the fetch request with (sessionId=258818904, epoch=2233): FETCH_SESSION_ID_NOT_FOUND.
INFO [2019-10-18 12:09:01,078] [ReplicaFetcherThread-44-10][] org.apache.kafka.clients.FetchSessionHandler - [ReplicaFetcher replicaId=6, leaderId=10, fetcherId=44] Node 10 was unable to process the fetch request with (sessionId=518415741, epoch=4416): FETCH_SESSION_ID_NOT_FOUND.
INFO [2019-10-18 12:09:01,890] [ReplicaFetcherThread-32-9][] org.apache.kafka.clients.FetchSessionHandler - [ReplicaFetcher replicaId=6, leaderId=9, fetcherId=32] Node 9 was unable to process the fetch request with (sessionId=418200413, epoch=3634): FETCH_SESSION_ID_NOT_FOUND.
Run Code Online (Sandbox Code Playgroud)
卡夫卡消费者日志:
12:29:58,936 INFO [FetchSessionHandler:383] [Consumer clientId=bannerGroupMap#87e2af7cf742#test, groupId=bannerGroupMap#87e2af7cf742#test] Node …
Run Code Online (Sandbox Code Playgroud) 我有很多很多FETCH_SESSION_ID_NOT_FOUND
INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=2] Node 1 was unable to process the fetch request with (sessionId=1229568311, epoch=511): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler)
INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=5] Node 1 was unable to process the fetch request with (sessionId=136816338, epoch=504): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler)
INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=2] Node 0 was unable to process the fetch request with (sessionId=311282207, epoch=569): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler)
...
Run Code Online (Sandbox Code Playgroud)
我阅读了Kafka:连续获取 FETCH_SESSION_ID_NOT_FOUND和如何检查 Kafka 集群中使用的增量获取会话缓存槽的实际数量?
目前,我们刚刚从Burrow获得了有关滞后的指标。
我的问题:
1、谁能解释一下为什么我有这么多FETCH_SESSION_ID_NOT_FOUND
?这是什么意思?我之前没有得到它们。
有些消费者发送了太多请求?还是领导人总是连任?
我不知道。有人可以给我更多细节吗?
2、如果是因为某些消费者发送的请求过多,如何识别这些消费者?
谢谢
apache-kafka ×2