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

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

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

这运行好几个小时，但我稍后在kafka.consumer.SimpleConsumer上得到一个例外：由于套接字错误重新连接：

java.nio.channels.ClosedChannelException

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

Answer 1

我也遇到了类似的问题，只是升级到最新版本的kafka为我修复了它。