Skip to main content

Client Java 2.8.2

  • Remove the uncorrected VisableTesting annotation in pulsar-client #11784
  • Fix packages tool parameter desc #11809
  • Add an optional params scope for pulsar oauth2 client #11931
  • Fix producer data race to get cnx #13176
  • Send CloseProducer on timeout #13161
  • Let producer reconnect for state RegisteringSchema #12781
  • Use epoch to version producer's cnx to prevent early de… #12779
  • Pulsar Client: restore SchemaInfo.builder() API #12673
  • Remove invalid call to Thread.currentThread().interrupt(); #12652
  • Add additional error handling in auto partition update task MultiTopicsConsumerImpl #12620
  • Fix invalid firstSentAt in log message when timeout first time #12588
  • Update producer stats when producer close #12500
  • 'StartMessageId' and 'RollbackDuration' not working in MultiTopicsReader for non-partitioned topics #12308
  • Use failPendingMessages to ensure proper cleanup #12259
  • Auto-recovery after exception like out of direct memory #12170
  • Fix endless receiveAsync loop in MultiTopicsConsumer #12044
  • Make Audience Field Optional in OAuth2 Client Credentials #11988
  • Forget to update memory usage on producer close #11906
  • Fix ConcurrentModificationException in sendAsync #11884
  • Hide option -s and substitute -ss(0) for it #11828
  • Fix seek at batchIndex level receive duplicated messages #11826
  • Reduce redundant FLOW requests for non-durable multi-topics consumer #11802
  • Add close method in the class of NegativeAcksTracker #12469
  • Fix a typo in UnAckedMessageTracker #12467
  • Fix message being ignored when the non-persistent topic reader reconnect. #12348
  • Fix deadLetterPolicy is not working with key shared subscription under partitioned topic #12148
  • Forget to call SendCallback on producer close #11939