apache/pulsar v2.7.2

on GitHub

Official release notes:
http://pulsar.apache.org/release-notes/#2.7.2

Download area:
http://pulsar.apache.org/en/download/

Broker

• Fix the useless retry when the maximum number of subscriptions is reached #9991
• wrong timeunit in updating lastLedgerCreationInitiationTimestamp #10049
• Avoid spammy logs in case of BK problems #10088
• Fix NonDurableCursorImpl initialPosition by startCursorPosition greater than lastConfirmedEntry problem. #10095
• fix 8115 Some partitions get stuck after adding additional consumers to the KEY_SHARED subscriptions #10096
• Add underReplicate state in the topic internal stats #10013
• Continue graceful shutdown even if web service closing fails #9835
• Issue 9804: Allow to enable or disable the cursor metrics #9814
• Allow to configure BookKeeper all BK client features using bookkeeper_ prefix #9232
• Fix NPEs and thread safety issue in PersistentReplicator #9763
• Non Persistent Topics: Auto-create partitions even when the auto-creation is disabled #9786
• Issue 9602: Add schema type validation #9797
• Fix message not dispatch for key_shared sub type in non-persistent subscription #9826
• zkBookieRackAffinityMapping bug to support for bookkeeper dnsResolver #9894
• Messaging Fix delay message block #10078
• Make PersistentDispatcherMultipleConsumers.readMoreEntries synchronized #10435
• Fix issue in reusing EntryBatchIndexesAcks instances #10400
• Fix schema not added when subscribing an empty topic without schema #9853
• Support advertisedListeners for standalone #10297
• Fix schema ledger deletion when deleting topic with delete schema. #10383
• Fix primitive schema upload for ALWAYS_COMPATIBLE strategy. #10386
• Fix schema type check issue when use always compatible strategy #10367
• Fix CPU 100% when deleting namespace #10337
• add return statement to exit asyncMarkDelete early on failure #10272
• Adding more permits debug statements to better diagnose permit issues #10217

Bookie

• Fallback to PULSAR_GC if BOOKIE_GC is not defined #9621
• Fallback to PULSAR_EXTRA_OPTS if BOOKIE_EXTRA_OPTS isn't defined #10397

Dependency upgrade

• Upgrade Bouncy Castle to 1.68 #9199
• Upgrade athenz version and remove yahoo.bintray.com repository #10471
• Upgrade Netty version to 4.1.60.final #10073
• Upgrade commons-io to address CVE-2021-29425 #10287
• Upgrade Jetty libraries to 9.4.39.v20210325 #10177

Proxy

• Issue 10221: Fix authorization error while using proxy and Prefix subscription authentication mode #10226

Pulsar Admin

• Add get version command for pulsar rest api, pulsar-admin, pulsar-client #9975

Pulsar SQL

• Using pulsar SQL query messages will appear NoSuchLedger… #9910

Docker

• Allow DockerImage to be built from source tarball #9846
• Fix docker standalone image error #10359
• Suppress printing of "skip Processing" lines in startup scripts #10275
• Issue 10058:apply-config-from-env.py to commented default values #10060

Client

• [Java] Fix: seemingly equal ClientConfigurationData's objects end up not being equal #10091
• [Java] Fix AutoConsumeSchema KeyValue encoding #10089
• [Java] Fix error OutOfMemoryError while using KeyValue<GenericRecord, GenericRecord> #9981
• [Java] Fix concurrency issue in incrementing epoch (#10278) #10436
• [Java] Allow pulsar client receive external timer #9802
• [Java] Handle NPE while receiving ack for closed producer #8979
• [Java] Fix batch size not set when deserializing from byte array #9855
• [Java] Fix ensure single-topic consumer can be closed #9849
• [Java] Issue 9585: delete disconnected consumers to allow auto-discovery #9660
• [Python] Support Python Avro schema set default value. #10265
• [Python] Fix nested Map or Array in schema doesn't work #9548
• [C++,Python] [PIP-60] Add TLS SNI support for cpp and python clients #8957
• [C++] Fix C++ client cannot be built on Windows #10363
• [C++] Fix paused zero queue consumer still pre-fetches messages #10036
• [C++] Fix segfault when get topic name from received message id #10006
• [C++] SinglePartition message router is always picking the same partition #9702
• [C++] Reduce log level for ack-grouping tracker #10094
• [WebSocket Client] WebSocket url token param value optimization #10187
• [WebSocket Client] Make the browser client support the token authentication #9886

Functions and Pulsar IO

• Allow customizable function logging #10389
• Pass through record properties from Pulsar Sources #9943
• ISSUE 10153: Pulsar Functions Go fix time unit ns -> ms #10160
• Kinesis Connector: Fix kinesis sink can not retry to send messages #10420
• Kinesis Connector: Fix null error messages in onFailure exception in KinesisSink. #10416

Tiered Storage

• Prevent Class Loader Leak; Restore Offloader Directory Override #9878
• Add logs for cleanup offloaded data operation #9852