- When a messageset is produced with the
RequiredAcks
set at 0, the waiting client will time out (if called withsend_sync
). This will also leak#waiter{}
records indorb_socket
; - CRC32 validation is not done on incoming messages;
- If a
dorb_socket
process crashes, it will leave callers waiting until they time out. (Fix is to monitor thedorb_socket
process and handle theDOWN
message gracefully - monitoring also returns aref
that could be reused).