v1.5.8

Version 1.5.8

What's Changed

Enhancements

• Handle socket errors by @hiimjako in #404
• Add golangci-lint static check by @hiimjako in #405
• Set inflight queue size to the initial credits by @hiimjako in #409
• Expose GetStreamName in HA Client by @hiimjako in #410

Bug Fixes

• Reverted PR #393 by @hiimjako in #411
• Avoid to panic on close when the consumer internal queue is full by @hiimjako in #412

Dependency Updates

• Bump golang.org/x/text from 0.25.0 to 0.26.0 by @dependabot in #399

New Contributors

• @LucasZhanye made their first contribution in #407

Full Changelog: v1.5.7...v1.5.8

v1.5.7

Version 1.5.7

Please read before updating.

• Read the 1.5 release notes
• Update go version to 1.23

What's Changed

Bug Fixes

• Fix data race in super stream producer by @yurahaid in #397

New Contributors

• @streamdp made their first contribution in #398

Full Changelog: v1.5.6...v1.5.7

v1.5.6

Version 1.5.6

Please read before updating.

• Read the 1.5 release notes
• Update go version to 1.23

What's Changed

Bug Fixes

• Fix panic when response failed by timeout by @yurahaid in #396

Full Changelog: v1.5.5...v1.5.6

v1.5.5

Version 1.5.5

Please read before updating.

• Read the 1.5 release notes
• Update go version to 1.23

What's Changed

Bug Fixes

• Fix producers reconnection deadlock by @yurahaid in #394
• Do not panic during chunk dispatching if consumer suddenly closed by @rsperl in #393

Dependency Updates

• Bump golang.org/x/net from 0.36.0 to 0.38.0 by @dependabot in #395

New Contributors

• @rsperl made their first contribution in #393

Full Changelog: v1.5.4...v1.5.5

v1.5.4

Version 1.5.4

Please read before updating.

• Read the 1.5 release notes
• Update go version to 1.23

What's Changed

Bug Fixes

• Fix handling and storing offset by timestamp by @yurahaid in #392

Dependency Updates

• Bump golang.org/x/text from 0.24.0 to 0.25.0 by @dependabot in #391

New Contributors

• @yurahaid made their first contribution in #392

Full Changelog: v1.5.3...v1.5.4

v1.5.3

Version 1.5.3

Please read before updating.

• Read the 1.5 release notes
• Update go version to 1.23

What's Changed

Enhancements

• Detect zombie consumer by @Gsantomaggio in #390

Full Changelog: v1.5.2...v1.5.3

v1.5.2

Version 1.5.2

Please read before updating.

• Read the 1.5 release notes
• Update go version to 1.23

What's Changed

• Bump golang.org/x/text from 0.23.0 to 0.24.0 by @dependabot in #389
• Reuse the locator connection. by @Gsantomaggio in #388
• Remove one heartbeat Ticket. by @Gsantomaggio in #388

Bug Fixes

• Fix an edge case during reconnection when the metadata fails by @Gsantomaggio in #388
• Fix a race condition for producer and consumer during the internal close. The internal close now has a cleanUp function by @Gsantomaggio in #388

Full Changelog: v1.5.1...v1.5.2

v1.5.1

Version 1.5.1

Please read before updating.

• Read the 1.5 release notes
• Update go version to 1.23

What's Changed

• Expose StoreOffset Api to the Env in #385 by @Gsantomaggio
• Update go version to 1.23

Dependency Updates

• Bump github.com/klauspost/compress from 1.17.9 to 1.18.0 by @dependabot in #381
• Bump github.com/golang/snappy from 0.0.4 to 1.0.0 by @dependabot in #384
• Bump github.com/spf13/cobra from 1.8.1 to 1.9.1 by @dependabot in #380
• Bump golang.org/x/text from 0.21.0 to 0.23.0 by @dependabot in #383
• Bump golang.org/x/net from 0.33.0 to 0.36.0 by @dependabot in #386

Full Changelog: v1.5.0...v1.5.1

v1.5.0

Version 1.5

What's Changed

Please read before updating.

This version focuses on stability during the reconnection and introduces the dynamic send.
There are no breaking changes, but deprecations:

• BatchPublishingDelay int is not used anymore.

Dynamic send

Dynamic send improves the latency when the traffic is low; for example, with 50 msg per second, there is ~3ms latency:

go run perftest.go --rate 50 --async-send
Published     42.9 msg/s | Confirmed     42.9 msg/s |  Consumed     42.9 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 3 ms
Published     43.8 msg/s | Confirmed     43.8 msg/s |  Consumed     43.8 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 3 ms
Published     44.4 msg/s | Confirmed     44.4 msg/s |  Consumed     44.4 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 3 ms
Published     45.0 msg/s | Confirmed     45.0 msg/s |  Consumed     45.0 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 2 ms

With the 1.4.x is~ 90ms (the aggregation timeout)

go run perftest.go --rate 50 --async-send
Published     44.4 msg/s | Confirmed     44.4 msg/s |  Consumed     44.4 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 88 ms
Published     45.0 msg/s | Confirmed     45.0 msg/s |  Consumed     45.0 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 89 ms
Published     45.5 msg/s | Confirmed     45.5 msg/s |  Consumed     45.5 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 90 ms

Enhancements

• Update to Golang 1.22
• Update the readers and random function deprecated
• Introduce the dynamic send in #367
• Increase the stability during the reconnection for Reliable Producers and Reliable Consumers in #367 and #371
• Performance improvement on unconfirmed map by @hiimjako in #374
• Set TCP parameters only if they are greater than 0 by @hiimjako in #375
• Add limit to the unconfirmed messages @Gsantomaggio #378
• Close TCP connection in case of CRC fails @Gsantomaggio in #378
• Replace map with syncmap @Gsantomaggio in #377

Bug Fixes

• Fix: #365
• Fix: #369
• Fix: #365

Thanks a lot to @hiimjako for helping with this version

Full Changelog: v1.5.0-beta.1...v1.5.0-rc.1

v1.5.0-rc.1

Version 1.5

What's Changed

Please read before updating.

This version focuses on stability during the reconnection and introduces the dynamic send.
There are no breaking changes, but deprecations:

• BatchPublishingDelay int is not used anymore.

Dynamic send

Dynamic send improves the latency when the traffic is low; for example, with 50 msg per second, there is ~3ms latency:

go run perftest.go --rate 50 --async-send
Published     42.9 msg/s | Confirmed     42.9 msg/s |  Consumed     42.9 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 3 ms
Published     43.8 msg/s | Confirmed     43.8 msg/s |  Consumed     43.8 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 3 ms
Published     44.4 msg/s | Confirmed     44.4 msg/s |  Consumed     44.4 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 3 ms
Published     45.0 msg/s | Confirmed     45.0 msg/s |  Consumed     45.0 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 2 ms

With the 1.4.x is~ 90ms (the aggregation timeout)

go run perftest.go --rate 50 --async-send
Published     44.4 msg/s | Confirmed     44.4 msg/s |  Consumed     44.4 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 88 ms
Published     45.0 msg/s | Confirmed     45.0 msg/s |  Consumed     45.0 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 89 ms
Published     45.5 msg/s | Confirmed     45.5 msg/s |  Consumed     45.5 msg/s |  Rate Fx: 50 | Body sz: 8 | latency: 90 ms

Enhancements

• Update to Golang 1.22
• Update the readers and random function deprecated
• Introduce the dynamic send in #367
• Increase the stability during the reconnection for Reliable Producers and Reliable Consumers in #367 and #371
• Performance improvement on unconfirmed map by @hiimjako in #374
• Set TCP parameters only if they are greater than 0 by @hiimjako in #375
• Add limit to the unconfirmed messages @Gsantomaggio #378
• Close TCP connection in case of CRC fails @Gsantomaggio in #378
• Replace map with syncmap @Gsantomaggio in #377

Bug Fixes

• Fix: #365
• Fix: #369
• Fix: #365

Thanks a lot to @hiimjako for helping with this version

Full Changelog: v1.5.0-beta.1...v1.5.0-rc.1