apache/pulsar v2.6.1

on GitHub

2.6.1 — 2020-08-21

The following lists fixes and enhancements in 2.6.1 release.

Broker

• [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

• [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

Java Client

• [Java Client] Fix the issue that the HTTP header used in Athenz authentication can not be renamed #7311
• [Java Client] Add more detail information of retry errors #7341
• [Java Client] Check NPE when a tombstone (null value) is produced. #7408
• [Java Client] Fix batch ackset recycled multiple times. #7409
• [Java Client] Support Oauth2 authentication #7420
• [Java Client] Ensure the create subscription can be completed when the operation timeout happens #7522
• [Java Client] Fix race condition on the close consumer while reconnecting to the broker. #7589
• [Java Client] Fix validation never return false #7593
• [Java Client] Make OAuth2 auth plugin to use AsyncHttpClient #7615
• [Java Client] Support to set listener name for client CLI #7621
• [Java Client] Fix batch index filter issue in Consumer #7654
• [Java Client] Fix the backward compatibility issues with batch index acknowledgment. #7655
• [Java Client] Fix the issue that batchReceiveAsync is not completed exceptionally when closing consumer #7661
• [Java Client] Fix producer stats recorder time unit error #7670
• [Java Client] Fix shutdown AsyncHttpConnector.delayer #7687

CPP Client

• [CPP Client] Fix partition index error in closing callback #7282
• [CPP Client] Reduce log level for ack-grouping tracker #7373
• [CPP Client] Support Oauth2 authentication #7467
• [CPP Client] Fix segment crashes that caused by race condition of timer in cpp client #7572
• [CPP Client] Fix multitopic consumer segfault on connect error #7588
• [CPP Client] Add support to read credentials from file #7606
• [CPP Client] Fix the issuer_url parsing failure in oauth2 #7791
• [CPP Client] Fix reference leak when reader create #7793

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