Pulsar-client-go Changelog

All notable changes to this project will be documented in this file.

[0.1.1] 2020-06-19

Improve

• Fixed batching flag logic
• Fix data race when accessing partition producer state
• Fixed tls connection issue
• Add flag to disable forced topic creation
• Add Athenz authentication provider
• Fixed race condition in producer Flush() operation
• Removed unnecessary flush in sync Send() operation
• Allow empty payload for nonbatch message
• Add internal connectionReader readAtLeast error information
• Fix zstd memory leak of zstdProvider
• Expose replicated from filed on message struct
• Fix send async comments
• Fix perf-produce cannot be closed
• Fix perf-producer target
• Fix fail to add batchbuilder
• skip debug print out when batch disabled with no messages
• Add check for max message size
• Build and test with multiple versions of Go
• When CGO is enabled, use C version of ZStd
• Stop partition discovery on Close
• Microbenchmark for compression
• Allow to have multiple connections per broker
• Increase writeRequestsCh channel buffer size

Contributors

Our thanks go to the following contributors from the community for helping this release:

• yarthur1
• vergnes
• sijie
• shustsud
• rueian
• mileschao
• keithnull
• abatilo
• cornelk
• equanz
• jerrypeng
• jonyhy96

[0.1.0] 2020-03-24

New Feature

Client

• Support TLS logic
• Support Authentication logic
• Support Proxy logic
• Support Hostname verification logic

Producer

• Add Send() method in Producer interface
• Add SendAsync() method in Producer interface
• Add LastSequenceID() method in Producer interface
• Add Flush() method in Producer interface
• Add Close() method in Producer interface
• Add Topic() method in Producer interface
• Add Name() method in Producer interface
• Support MessageRouter logic
• Support batch logic
• Support compression message logic
• Support HashingScheme logic
• Support User defined properties producer logic

Consumer

• Add Subscription() method in Consumer interface
• Add Unsubscribe() method in Consumer interface
• Add Receive() method in Consumer interface
• Add Ack() method in Consumer interface
• Add AckID() method in Consumer interface
• Add Nack() method in Consumer interface
• Add NackID() method in Consumer interface
• Add Seek() method in Consumer interface
• Add SeekByTime() method in Consumer interface
• Add Close() method in Consumer interface
• Support Dead Letter Queue consumer policy
• Support Topics Pattern and Topics logic
• Support topic consumer regx logic
• Support multi topics consumer logic
• Support Exclusive, Failover, Shared and KeyShared subscribe type logic
• Support Latest and Earliest logic
• Support ReadCompacted logic
• Support ReplicateSubscriptionState logic
• Support User defined properties consumer logic
• Support Delayed Delivery Messages logic

Reader

• Add Topic() method in Reader interface
• Add Next() method in Reader interface
• Add HasNext() method in Reader interface
• Add Close() method in Reader interface
• Support read compacted logic
• Support start messageID logic
• Support User defined properties reader logic

Contributors

Our thanks go to the following contributors from the community for helping this release:

• merlimat
• wolfstudy
• cckellogg
• xujianhai666
• reugn
• freeznet
• zzzming
• wty4427300
• stevenwangnarvar
• dsmlily
• banishee
• archfish
• Morsicus