TubeMQ has been donated to the Apache Software Foundation and renamed to InLong, please visit the new Apache repository: https://github.com/apache/incubator-inlong
When reading, the IOException only be checked , but when writing, any exception will cause the write to fail, which needs to be captured and processed.
this close https://github.com/Tencent/TubeMQ/issues/137