时间戳

首页 > 解决方案 > 无法处理 Kafka 中的获取请求

spring-boot - 无法处理 Kafka 中的获取请求

问题描述

我正在使用 Spring boot 和 Kafka（不是 Spring Kafka）来使用生产者生成的关于该主题的消息。这工作正常，没有任何问题。我想了解的是以下消息。每当有东西产生时，我都可以根据我的逻辑阅读它，现在，只需在控制台上打印它。但是，当什么都没有产生时，我会不断收到以下消息。它不会导致任何失败。请帮助我理解这是什么意思。我需要做些什么来处理它吗？我正在使用 Kafka 2.4.0 版。

2020-07-06 17:30:22.295  INFO 12908 --- [  restartedMain] o.a.kafka.clients.FetchSessionHandler    : [Consumer clientId=consumer-group12-1, groupId=group12] Node 72 was unable to process the fetch request with (sessionId=725943037, epoch=240): FETCH_SESSION_ID_NOT_FOUND.
    2020-07-06 17:32:29.957  INFO 12908 --- [  restartedMain] o.a.kafka.clients.FetchSessionHandler    : [Consumer clientId=consumer-group12-1, groupId=group12] Node 72 was unable to process the fetch request with (sessionId=541437574, epoch=162): FETCH_SESSION_ID_NOT_FOUND.
    2020-07-06 17:34:32.871  INFO 12908 --- [  restartedMain] o.a.kafka.clients.FetchSessionHandler    : [Consumer clientId=consumer-group12-1, groupId=group12] Node 72 was unable to process the fetch request with (sessionId=559071905, epoch=155): FETCH_SESSION_ID_NOT_FOUND.
    2020-07-06 17:36:43.513  INFO 12908 --- [  restartedMain] o.a.kafka.clients.FetchSessionHandler    : [Consumer clientId=consumer-group12-1, groupId=group12] Node 72 was unable to process the fetch request with (sessionId=225929150, epoch=166): FETCH_SESSION_ID_NOT_FOUND.
    2020-07-06 17:38:52.561  INFO 12908 --- [  restartedMain] o.a.kafka.clients.FetchSessionHandler    : [Consumer clientId=consumer-group12-1, groupId=group12] Node 72 was unable to process the fetch request with (sessionId=1829710146, epoch=164): FETCH_SESSION_ID_NOT_FOUND.
    2020-07-06 17:44:07.219  INFO 12908 --- [  restartedMain] o.a.kafka.clients.FetchSessionHandler    : [Consumer clientId=consumer-group12-1, groupId=group12] Node 72 was unable to process the fetch request with (sessionId=1766828327, epoch=396): FETCH_SESSION_ID_NOT_FOUND.

标签： spring-bootapache-kafka

解决方案

推荐阅读