freeznet opened a new pull request #400:
URL: https://github.com/apache/pulsar-client-go/pull/400
Fixes #172
### Motivation
Add a new batch message container named `keyBasedBatchContainer` to support
batching message in key_shared subscription mode.
### Modifications
- add `BatchBuilder` interface, add `FlushBatches` and `IsMultiBatches` func
- change old `BatchBuilder` struct to `batchContainer`
- add `keyBasedBatchContainer`
- add tests
### Verifying this change
This change added tests and can be verified as follows:
- *Added integration tests for key based batch producer with multiple
consumer in KeyShared mode*
- *Added integration tests for message ordering with key based batch
producer and KeyShared consumer*
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
