当前位置:  开发笔记 > 大数据 > 正文

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

如何解决《ApacheKafka:由于java.io.IOIO导致会话<xx>关闭的异常:长度不合理》经验,为你挑选了0个好方法。

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

有什么想法吗??

推荐阅读
php
这个屌丝很懒,什么也没留下!
DevBox开发工具箱 | 专业的在线开发工具网站    京公网安备 11010802040832号  |  京ICP备19059560号-6
Copyright © 1998 - 2020 DevBox.CN. All Rights Reserved devBox.cn 开发工具箱 版权所有