Pulsar Client Go

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