Skip to main content

Apache Pulsar 2.6.1


The following lists fixes and enhancements in 2.6.1 release.


  • [Broker] Limit batch size to the minimum of the maxNumberOfMessages and maxSizeOfMessages #6865
  • [Broker] Fix hash range conflict issue in Key_Shared with sticky hash range #7231
  • [Broker] Fix the issue that get lookup permission error #7234
  • [Broker] Update Jetty to version 9.4.29 #7235
  • [Broker] Fix readers backlog stats after data is skipped #7236
  • [Broker] Fix the regression in isSupperUser #7241
  • [Broker] Avoid introducing null read position for the managed cursor #7264
  • [Broker] Fix permission operation check on setRetention admin operation #7281
  • [Broker] Fix error in creation of non-durable cursor #7355
  • [Broker] Fix bug related to managedLedger properties #7357
  • [Broker] Add tenant name check in list namespaces function #7369
  • [Broker] Avoid the NPE occurs in method ManagedLedgerImpl.isOffloadedNeedsDelete #7389
  • [Broker] Fix producer stuck issue due to NPE thrown when creating a new ledger #7401
  • [Broker] Avoid NPEs at ledger creation when DNS failures happen #7403
  • [Broker] Support decompression payload if needed in KeyShared subscription #7416
  • [Broker] Fix update-cluster cli updates proxy-url #7422
  • [Broker] Handle NotAllowed Exception at the client side #7430
  • [Broker] Shade jclouds to avoid Gson conflict #7435
  • [Broker] Consumer is registered on dispatcher even if hash range conflicts on Key_Shared subscription #7444
  • [Broker] Add pulsar-client-messagecrypto-bc into pulsar-client dependency to avoid method not found #7447
  • [Broker] Fix update partitions error for non-persistent topic #7459
  • [Broker] Use CGroup CPU usage when present #7475
  • [Broker] Fix ArrayIndexOutOfBoundsException when dispatch messages to consumer #7483
  • [Broker] Get last entry is trying to read entry -1 #7495
  • [Broker] Fix timeout opening managed ledger operation #7506
  • [Broker] Fixes the exception that occurred when the geo-replication policy is updated #7514
  • [Broker] Update Jackson to version 2.11.1 and ensure all dependencies are pinned #7519
  • [Broker] Fix protobuf generation on handling repeated long number #7540
  • [Broker] Add more logging to the auth operations on failure #7567
  • [Broker] Use Consume/Produce/Lookup interfaces for specific operations in allowTopicOperation #7587
  • [Broker] Support configuring DeleteInactiveTopic setting in namespace policy #7598
  • [Broker] Fix NPE when using advertisedListeners #7620
  • [Broker] Fix the issue that deduplication cursor can not be deleted after disabling message deduplication #7656
  • [Broker] Add missing AuthenticationDataSource to canConsumeAsync method call #7694
  • [Broker] Close the previous reader of the health check topic #7724
  • [Broker] Change some WebApplicationException log level to debug #7725
  • [Broker] Replay delayed messages in order #7731
  • [Broker] Fix the wrong returned URL for lookup when specify advertised listener #7737
  • [Broker] Fix topic getting recreated immediately after deletion #7524
  • [Broker] Set default root log level to debug #7789
  • [Broker] Fix producer stucks on creating ledger timeout #7319
  • [Broker] AllowTopicOperationAsync should check the original role is super user #7788


  • [Zookeeper] Use hostname for bookie rackawareness mapping #7361

Pulsar SQL

  • [Pulsar SQL] Make Pulsar SQL get correct offload configurations #7701

Pulsar Schema

  • [Schema] Fix the error that occurs when getting schemaName by partitioned topic name #7708

Pulsar Functions

  • [Pulsar Function] Use fully qualified hostname as default to advertise worker #7360
  • [Pulsar Function] Fix the function BC issue introduced in release 2.6.0 #7528
  • [Pulsar Function] Improve security setting of Pulsar Functions #7578
  • [Pulsar Function] Differentiate authorization between source/sink/function operations #7466

Go Function

  • [Go Function] Fix Go instance config port #7322
  • [Go Function] Remove timestamp from metrics #7539

Pulsar Perf

  • [Pulsar Perf] Supports tlsAllowInsecureConnection in pulsar-perf produce/consume/read #7300