ming

This PR allows to add customized labels based on HTTP header. A custom reporter can define a list of customized labels. A new function CustomHeader can parse the header and...

[issue #807] dlq topic producer options

3

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...

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...

### 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...

build pulsar-perf for multiple os and architecture

1

### Motivation To release a pulsar-perf utility against multiple popular OS and architecture, these binaries can be generated and part of the pulsar-client-go release. Can these binaries in gz format...

Implement TLS VerifyPeerCertificate callback to skip hostname verfication

4

### Contribution Checklist This PR addresses a problem how to disable TLS ValidateHostname. The current implementation with empty `tlsConfig.ServerName` would not work, because the connected server host will be inferred...

The detail is explained by https://github.community/t/make-secrets-available-to-builds-of-forks/16166/20 We need to rewrite the test cases to avoid using secrets

[DO NOT MERGE] This is a temporary fix Support all subjection options in JWT - tenant - tenant-client - tenant-client-hash These variations are introduced by JWT token generation, since the...

The work load of pushing data to webhooks are within a single process. To scale up, we shall be able to have multiple brokers/workers to share the load. The first...

trigger CI

1

this is a PR just to test the CI.