Error sending fetch request (sessionId=INVALID, epoch=INITIAL) 是什么意思?

開開新新 发表于: 2022-08-26   最后更新时间: 2022-08-26 15:10:27   3,368 游览
[2022-08-26T15:04:19,945][INFO ][org.apache.kafka.clients.FetchSessionHandler][scheduler_dev][395b73ccd346e974aaf66c44f1191c83f554543b4a00f3d046b00ca0cf1ec435] [Consumer clientId=scheduler-01-0, groupId=scheduler-01] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2001: {}.
org.apache.kafka.common.errors.DisconnectException: null
[2022-08-26T15:04:58,579][INFO ][org.apache.kafka.clients.FetchSessionHandler][scheduler_dev][395b73ccd346e974aaf66c44f1191c83f554543b4a00f3d046b00ca0cf1ec435] [Consumer clientId=scheduler-01-0, groupId=scheduler-01] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2003: {}.
org.apache.kafka.common.errors.DisconnectException: null
[2022-08-26T15:05:00,099][INFO ][org.apache.kafka.clients.FetchSessionHandler][scheduler_dev][395b73ccd346e974aaf66c44f1191c83f554543b4a00f3d046b00ca0cf1ec435] [Consumer clientId=scheduler-01-0, groupId=scheduler-01] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2001: {}.
org.apache.kafka.common.errors.DisconnectException: null
[2022-08-26T15:05:00,099][INFO ][org.apache.kafka.clients.FetchSessionHandler][scheduler_dev][395b73ccd346e974aaf66c44f1191c83f554543b4a00f3d046b00ca0cf1ec435] [Consumer clientId=scheduler-01-0, groupId=scheduler-01] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2002: {}.
org.apache.kafka.common.errors.DisconnectException: null

日志级别是INFO,但是触发 “org.apache.kafka.common.errors.DisconnectException: null”,这个错误是什么意思?

这个日志是我的client端拿到的,那么kafka server端会有相关的错误信息日志吗?有的话会在哪个日志文件中?

发表于 2022-08-26
添加评论

kafka server没有相关的错误。

因为这个信息是info的,客户端会重试。

这个断开异常是由于拉取超时导致的,你可以通过增加请求超时,解决这个问题。

consumer.request.timeout.ms:
你的答案

查看kafka相关的其他问题或提一个您自己的问题