阿帕奇卡夫卡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消费者执行提取操作时,我看到一个。
有什么想法吗??
| 归档时间: |
|
| 查看次数: |
832 次 |
| 最近记录: |