问题描述
我通过ssh连接到服务器，启动了zookeper kafka和debezium连接器，过了一会儿，只有kafka终端选项卡被踢出，并出现以下错误 packet_write_wait:连接到**.**.***.***端口22:管道损坏
i connect to server through ssh, i launch my zookeper kafka, and my debezium connector, after a while only the kafka terminal tab get's kicked out with the following errorpacket_write_wait: Connection to **.**.***.*** port 22: Broken pipe
我的连接器输出是:
>>>>[2019-07-10 10:04:49,563] WARN [Producer clientId=producer-1] >>>>Connection to node 0 (ip-***.**.**.***.eu-
>>>>west-3.compute.internal/***.**.**.***:9092) could not be established.
>>>>Broker may not be available.
>>>>(org.apache.kafka.clients.NetworkClient:725)
>>>>[2019-07-10 10:04:49,676] ERROR WorkerSourceTask{id=mongodb-source-
>>>>connector-0} Failed to flush, timed out while waiting for producer to
>>>>flush outstanding 8 messages
>>>>(org.apache.kafka.connect.runtime.WorkerSourceTask:420)
>>>>[2019-07-10 10:04:49,676] ERROR WorkerSourceTask{id=mongodb-source-
>>>>connector-0} Failed to commit offsets
>>>>(org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:111)
我不想每次都手动重新启动，如何解决此问题，所以我只能ssh一次启动服务器和连接器然后退出?.
i don't want to restart manually everytime that happends, how can i fix this so i can only ssh one time launch the servers and connector then exit?.
推荐答案
好的，所以我做了sudo systemctl启用confluent-zookeepersudo systemctl启用合流卡夫卡sudo systemctl启动汇合的zookeeper我收到文件错误的访问权限，已将其更改为chmod，现在Zookeeper正常运行.须藤systemctl启动汇合-kafka我仍然无法解决错误，这是输出
Alright so what i did was sudo systemctl enable confluent-zookeepersudo systemctl enable confluent-kafkasudo systemctl start confluent-zookeeperi got a acces to file error, i've chmod it and now zookeeper works fine.sudo systemctl start confluent-kafkai got a error still couldn't fix , this is the output
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102)
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107)
at sun.nio.fs.UnixFileSystemProvider.newFileChannel(UnixFileSystemProvider.j
at java.nio.channels.FileChannel.open(FileChannel.java:287)
at java.nio.channels.FileChannel.open(FileChannel.java:335)
at org.apache.kafka.common.record.FileRecords.openChannel(FileRecords.java:4
at org.apache.kafka.common.record.FileRecords.open(FileRecords.java:410)
at org.apache.kafka.common.record.FileRecords.open(FileRecords.java:419)
这篇关于管道断开后如何修复经纪人可能不可用的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！