pulsar-client-go
pulsar-client-go copied to clipboard
apache
Apache Pulsar Go Client Library
**Is your feature request related to a problem? Please describe.** No **Describe the solution you'd like** When receiving the batched messages, Golang consumer can build a intermediate ack_tracker that keeps...
## Problem Some messages send by Asyn. The messages in the batch may have many identical msgids.If we Ack a batch message, then all batches will be confirmed ## We...
Signed-off-by: xiaolongran ### Motivation Currently, when Go SDK creates a connection, the version information set is fixed to Pulsar Go 0.1. When we maintain multiple versions of Go SDK in...
### Motivation currently we have `github.com/spf13/cobra v1.2` dependency, which depends on `spf13/viper` (which is a heavy mod) the good news is that github.com/spf13/cobra version >= v1.4.0 [has `viper` mod dependency...
### Contribution Checklist Master issue: [issue 816 ](https://github.com/apache/pulsar-client-go/issues/816) ### Motivation support consumer to send ack request and get response synchronously ### Modifications 1. add closeCh waiting after send ackRequest 2....
### Motivation Fix up logrusWrapper I think that's a typo, I found it today when I'm implementing [a zap logger wrapper](https://github.com/ttys3/pulsarzap). ### Modifications as the code ### Verifying this change...
#### Expected behavior When I set consumer option AckWithResponse = true, should return some err when ack fail #### Actual behavior req.err always be nil #### Steps to reproduce ####...
Fixes #447 ### Motivation Try to fix issue #447. ### Modifications Compress the payload when the payload is too bigger, and check whever the 'compressed payload' is still bigger than...
Fixes #807 ### Motivation To customize producer options for DLQ topics. ### Modifications Add DLQProducerOptions to consumer's DLQ policy. ### Verifying this change - [ ] Make sure that the...
### Motivation A vulnerability scan on this repository found a vulnerable version of `gopkg.in/yaml.v3`. https://github.com/advisories/GHSA-hp87-p4gw-j4gq We need to upgrade the version of `github.com/stretchr/testify` because it directly depends on `gopkg.in/yaml.v3`. https://github.com/stretchr/testify/pull/1192...
