[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端会有相关的错误信息日志吗?有的话会在哪个日志文件中?
kafka server没有相关的错误。
因为这个信息是info的,客户端会重试。
这个断开异常是由于拉取超时导致的,你可以通过增加请求超时,解决这个问题。
consumer.request.timeout.ms:
你的答案