小编use*_*232的帖子

阿帕奇卡夫卡0.9.0

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

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

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

有什么想法吗？？