Skip to main content

Pulsar Client Go

What's Changed

  • [feat] Add eventTime support in reconsumeLaterWithCustomProperties() (#1400) by @YoungCoderboy
  • [fix] Replace panic with proper error handling in RPC client and lookup service (#1403) by @RobertIndie
  • [fix] DLQ messages lost system properties when sent from reconsumeLater() (#1392) by @geniusjoe
  • [fix] Handle reconnection logic for zero-queue consumer (#1404) by @crossoverJie
  • [fix] Add DLQPolicy.DeadLetterTopicProducerName to preserve producer name in DLQ messages (#1417) by @thomas-bousquet
  • [fix] Fix missing topic in DLQ producer name when using RetryEnable option (#1412) by @geniusjoe
  • [fix] SendAsync now respects context and can timeout during reconnection (#1422) by @RobertIndie
  • [fix] Improve zero-queue consumer support for partitioned topics (#1424) by @crossoverJie
  • [fix] Properties not consistently set in pulsar-admin subscription responses (#1419) by @JamesMurkin
  • [feat] Support Snappy compression type (#1406) by @geniusjoe
  • [feat] Add WithContext() admin client methods (#1425) by @thomas-bousquet
  • [feat] Add support for max topics per namespace (#1413) by @miton18
  • [fix] Allow multiple callbacks with concurrent producer flushes (async publish) (#1409) by @thomas-bousquet
  • [improve] Change pulsar_client_sending_buffers_count metric to client level (#1408) by @BewareMyPower
  • [chore] Upgrade hamba/avro to v2.29.0 (#1414) by @nodece
  • [chore] Bump github.com/go-viper/mapstructure/v2 from 2.2.1 to 2.4.0 (#1415) by @dependabot[bot]
  • [chore] Bump github.com/docker/docker from 27.1.1+incompatible to 28.0.0+incompatible (#1405) by @dependabot[bot]

New Contributors

  • @YoungCoderboy made their first contribution in #1400
  • @JamesMurkin made their first contribution in #1419