rabbitmq-stream-go-client

rabbitmq-stream-go-client copied to clipboard

Heartbeat service in v2

1

## Summary Implement a mechanism to receive and send heartbeats. Heartbeats should be sent when there are inactivity periods, for example, when the client is inactive (no locator operations) for...

Zerpet

Smart Producer for v2

4

## Description We have to implement the smart producer, similar as the [v1 Producer](https://pkg.go.dev/github.com/rabbitmq/rabbitmq-stream-go-client/pkg/stream#Producer). However, I’d like to take the chance that we are doing a major and change the...

Zerpet

Looks good to me. Publish error is not tested in the `e2e` test btw _Originally posted by @Gsantomaggio in https://github.com/rabbitmq/rabbitmq-stream-go-client/pull/220#pullrequestreview-1557098094_ Based on feedback above, we should add an E2E test...

Zerpet

go-stream-locator

4

### Describe the bug Our service using rabbitmq-stream-go-client gets stuck at random times resulting in downtime. The issue starts when the RabbitMQ server logs "unknown command". ¤ unknown command {request,11,{close,1,}},...

Rozztig

consumer offsets a bit unclear

1

### Is your feature request related to a problem? Please describe. Hello! In my project I've to manually track offsets. It's done in a different (main) goroutine, while the consumer...

HustonMmmavr

### Is your feature request related to a problem? Please describe. Create a way to TAG and release automatically ### Describe the solution you'd like Create a way to TAG...

Gsantomaggio

Heartbeats misleading behaviour

1

### Is your feature request related to a problem? Please describe. Hello! There is a question about hearbeats, for example the next code would raise to logs next messages Code:...

HustonMmmavr

The CI fails on publish the docker image

2

### Describe the bug The CI fails on publish the docker image see https://github.com/rabbitmq/rabbitmq-stream-go-client/actions/runs/9363102441 ### Reproduction steps The CI fails on publish the docker image see https://github.com/rabbitmq/rabbitmq-stream-go-client/actions/runs/9363102441 ### Expected behavior...

Gsantomaggio

Bumps [github.com/klauspost/compress](https://github.com/klauspost/compress) from 1.17.9 to 1.17.11. Release notes Sourced from github.com/klauspost/compress's releases. v1.17.11 What's Changed zstd: Fix extra CRC written with multiple Close calls by @​klauspost in klauspost/compress#1017 s2: Don't...

dependabot[bot]

### Describe the bug The CI often fails on windows. I am not able to reproduce the problem locally ### Reproduction steps The CI often fails on windows. I am...

Gsantomaggio