pulsar-client-go

pulsar-client-go copied to clipboard

[Issue 456] Support chunking for big messages.

2

### Contribution Checklist Master Issue: [#456](https://github.com/apache/pulsar-client-go/issues/456) ### Motivation Make pulsar go client support chunking to produce/consume big messages. The earlier implementation ([#717](https://github.com/apache/pulsar-client-go/pull/717)) didn't take into account many details, so I...

Gleiphir2769

[Issue 827][bugfix] fix error delay of default backoff policy

1

Signed-off-by: simonisacoder Fixes [#issue 827](https://github.com/apache/pulsar-client-go/issues/827) Master Issue: # ### Motivation *Explain here the context, and why you're making that change. What is the problem you're trying to solve.* ### Modifications...

simonisacoder

#### Expected behavior int the `pulsar/negative_backoff_policy.go` file, the Next function declare two variables ```go minNackTimeMs := int64(1000 * 30) and comment "30 sec" maxNackTimeMs := 1000 * 60 * 10...

simonisacoder

Makefiles are commonly used for building golang projects. - add a Makefile with basic build, test, clean, etc. - simplify the Dockerfile by moving some scripts and conf files to...

pgier

Add ClientOptions.MetricsRegisterer for customizing prometheus metrics registerer. ### Motivation Currently, client always use `prometheus.DefaultRegisterer` to register metrics, but the application might already have a registerer for metrics registering and exporting....

pragkent

[client] Rename `test_helper.go` to follow the test code naming convention

2

### Motivation Package private functions and variables, defined in `pulsar/test_helper.go`, are called from test codes. However, it is recognized as a non-test code by Go Modules because it doesn't follow...

equanz

 NackBackoffPolicy.Next return int64 type before, but it used as time.Durtion. 

h-hy

[Issue 489] TLS fix for certificate that does not include IP SANS, save hostname before switching to physical addr

2

*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes # *(or if this PR is one task of a github issue, please add `Master Issue: #` to...

dinghram

Fixes https://github.com/apache/pulsar/issues/16973 *(or if this PR is one task of a github issue, please add `Master Issue: #` to link to the master issue.)* Master Issue: # ### Motivation *Explain...

leizhiyuan

[issue 679][oauth2] Fix macos compiler warnings, remove store impleme…

7

…nt keyring which not used at all Master Issue: #719 ### Motivation Fix MacOS version warning from the unused OAuth2 store implement named keyring.go ### Modifications To fix the warning...

llqgit