pulsar-client-go

pulsar-client-go copied to clipboard

Fixes #456 ### Motivation Allow go clients to send and receive large messages in chunks. ### Modifications ### Verifying this change - [ ] Make sure that the change passes...

ShuaoZhang

multiple reader fix comment

1

fix comment

EAHITechnology

reader subscribe all partitioned topics

1

Initial changes to address reader topic not found issue: https://github.com/apache/pulsar-client-go/issues/553 Changes: - create multi-topic reader

GPrabhudas

client option to set DefaultMaxMessageSize

1

### Motivation When the broker sets maxMessageSize more than 5MB, the go client can still get error `message size exceeds MaxMessageSize`. Upon some conditions, the broker is not communicate the...

zzzming

Add parition reader to solve the Reader fragmented read data.

2

- fix issues #553 [detail](https://github.com/apache/pulsar-client-go/issues/553) list: - add partition reader file; /pulsar/reader_partition.go - update reader Impl /pulsar/reader_impl.go ;

EAHITechnology

### Motivation A group of batch counters are not properly critical section protected in the producer's default_router. Read and update of these counters should be protected as a whole, instead...

zzzming

Close the old connection to make sure the broker drops the producer on its side

1

Master Issue: #676 ### Motivation When reconnecting to the server, the old connection should be closed. ### Modifications Close the old connection to make sure the broker drops the producer...

wenbingshen

[feature] expose error to user when producer reconnect to broker failed

2

Create producer failed will return error message to user. In some case broker notify producer close and producer can't reconnect broker successfully, but we can't get the error message when...

yorkhellen

Fixes #640 Master Issue: #640 go client create producer and consumer client way is different with java client. and go client will throw error when call grabCnx while Lookup or...

baomingyu

### Modifications Produce a more meaningful error when the issuer url is not specified. ### Verifying this change This change is a trivial rework / code cleanup without any test...

EronWright