kafka.consumer.SimpleConsumer：由于套接字错误而重新连接：java.nio.channels.ClosedChannelException

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了kafka.consumer.SimpleConsumer：由于套接字错误而重新连接：java.nio.channels.ClosedChannelException，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1132字，纯文字阅读大概需要2分钟。

内容图文

我正在为kafka运行一个简单的消费者,例如：

int timeout = 80000;
int bufferSize = 64*1024;
consumer = new SimpleConsumer(host, port,timeout, bufferSize, clientName);

这可以正常运行几个小时,但出现异常
稍后的
kafka.consumer.SimpleConsumer：由于套接字错误而重新连接：

java.nio.channels.ClosedChannelException

消费者停止了……以前有人遇到过这个问题吗？

解决方法:

一个稍有不同的问题,但也许具有相同的根本原因和解决方案是answered here,相关部分：

You have closed the channel and are still trying to use it.

There are several issues with your code.

First, your test for EOS is faulty. Remove the limit() == 0 test. That
doesn’t indicate EOS, it just indicates a zero length read, which can
happen in non-blocking mode at any time. It doesn’t mean the peer has
closed his end of the connection, and it doesn’t mean you should close
your end.

Second, closing a channel closes the socket as well. You should close
the channel only, not the socket.

Third, closing a channel cancels the key. You don’t need to follow
every close with a cancel.

You may also have failed to check whether a ready key is valid in the
select loop before using it, e.g. for reading.

内容总结

以上是互联网集市为您收集整理的kafka.consumer.SimpleConsumer：由于套接字错误而重新连接：java.nio.channels.ClosedChannelException全部内容，希望文章能够帮你解决kafka.consumer.SimpleConsumer：由于套接字错误而重新连接：java.nio.channels.ClosedChannelException所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端