Apache Kafka:由于java.io.IOIO导致会话<xx>关闭的异常:长度不合理

use*_*232 5 apache-kafka

阿帕奇卡夫卡0.9.0

尝试通过使用者执行提取操作时,我在zookeeper日志中遇到了上述异常。这是我在使用者上创建提取请求的方式:

kafka.api.FetchRequest req = new FetchRequestBuilder().clientId(clientId)
                                                      .addFetch(topic, 0, 0L, 100)
                                                      .build();
FetchResponse fetchResponse = simpleConsumer.fetch(req);
Run Code Online (Sandbox Code Playgroud)

java.io.EOFException消费者执行提取操作时,我看到一个。

有什么想法吗??