myzhan / avroipc

Avroipc is a pure-go-implemented client for flume's avro source
MIT License
4 stars 6 forks source link

Flush data from buffer on closing #33

Closed vykulakov closed 4 years ago

vykulakov commented 4 years ago

Now there is a bug with the buffered transport and if there are some bytes in the buffer before closing the transport they will be silently ignored. It does not create any problem with communication with a Flume server because there is no closing procedure and we can just loose only some unnecessary data of zlib transport. That's all.