Release Candidate 1
This version introduces breaking changes (#88, #101)
Bug Fixes
- nil reference when target server is down #98 (Contributed by @victorges )
Enhancements
- SubEntry batch #86. It is possible to aggregate more messages in a single send. With
SetSubEntrySize(xxx)you can define the aggretazion size.SetSubEntrySize(1).is the default (no aggregation) - Compression for SubEntry batch #97. It is possible to compress the payload in different ways.
- TCP write improvements. Write directly using the TCP socket writer.
- Refactor Confirmation #88. Breaking Changes
- Confirmation handler: Messages status in ready only mode:
for _, msg := range confirmed { ... msg.GetMessage().GetData() /// <-- readonly
- Improve the HA producer with
BatchSend - Make stream creation idempotent #101. Breaking Changes
- Refactor TCP with #87
- Configure TCP parameters #94
- Improve message error in case of connection problems. #95 e191752
Performance test
Add parameters for subEntry batch and compression ex:
stream-perf-test --sub-entry-size 100 --compression gzip