阿帕奇卡夫卡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
消费者执行提取操作时,我看到一个。
有什么想法吗??