pulsar-client-go
pulsar-client-go copied to clipboard
apache
Apache Pulsar Go Client Library
Fixes #387 ### Motivation Fix goroutine leak for closing consumers. ### Modifications Close the `c.messageCh` at the same time as closing the consumer. **Before fix:**  
**Is your feature request related to a problem? Please describe.** If I have a broker which is allowing connections, but is broken in some way that it disconnects from the...
The default BatchingMaxSize is 128K, and messages that exceed this size cannot be put into DLQ。
*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes #797 ### Motivation *Explain here the context, and why you're making that change. What is the problem you're...
### Motivation - add 0.9.0 changelog - bump VERSION and stable version ### Modifications *Describe the modifications you've done.* ### Verifying this change - [ ] Make sure that the...
I'm getting "message too large" messages on some large JSON documents that, when compressed, are nowhere near the limit. in `producer_partiton.go`: ```go // if msg is too large if len(payload)...
Receive method of Consumer returns Message directly, but if we want attach something(ex SpanContext) in Receive method to context, we can't bring it out without change type of Message interface....
Example code: ```go package main import ( "github.com/apache/pulsar-client-go/pulsar" "github.com/pkg/errors" "github.com/rs/zerolog/log" ) type UserPulsarMessage struct { FirstName string `json:"firstName"` LastName string `json:"lastName"` Gender *string `json:"gender"` } var schema = `{ "name":...
Signed-off-by: xiaolongran ### Motivation In #775 and #776, we support the error information that may occur when the Go SDK side processes the Ack Command, but there is a bug...
Fixes #664 ### Motivation Removing possible panic. ### Modifications Add nil check and more friendly tips. ### Verifying this change - [x] Make sure that the change passes the CI...