我正在为kafka运行一个简单的消费者，例如:
int timeout = 80000;
int bufferSize = 64*1024;
consumer = new SimpleConsumer(host, port,timeout, bufferSize, clientName);
这可以正常运行几个小时，但出现异常
稍后的
kafka.consumer.SimpleConsumer:由于套接字错误而重新连接:
消费者停止了……以前有人遇到过这个问题吗？
最佳答案
一个稍微不同的问题，但也许是相同的根本原因和解决方案是answered here，相关部分: