Apache Pulsar 2.6.2
2020-11-09
The following lists fixes and enhancements in the 2.6.2 release.
Broker
- [Broker] Catch throwable when start pulsar 7221
- [Broker] Protobuf-shaded package can not update version 7228
- [Broker] Check for null arguments in Namespaces Rest API 7247
- [Broker] Handle SubscriptionBusyException in resetCursor api 7335
- [Broker] Converted the namespace bundle unload into async operation 7364
- [Broker] Update Jersey to 2.31 7515
- [Broker] Stop to dispatch when skip message temporally since Key_Shared consumer stuck on delivery 7553
- [Broker] Fix bug where producer for geo-replication is not closed when topic is unloaded 7735
- [Broker] Make resetting cursor in REST API asynchronous 7744
- [Broker] Reestablish namespace bundle ownership from false negative releasing and false positive acquiring 7773
- [Broker] make pulsar executor pool size configurable 7782
- [Broker] Redirect Get message by id request when broker not serve for the topic 7786
- [Broker] Make zk cache executor thread pool size configurable 7794
- [Broker] Implement toString() method for TopicMessageIdImpl class 7807
- [Broker] Fix pending batchIndexAcks bitSet batchSize in PersistentAcknowledgmentsGroupingTracker 7828
- [Broker] Fix deadlock when adding consumer 7841
- [Broker] Split message ranges by ledger ID and store them in individualDeletedMessages 7861
- [Broker] Fix pulsar metrics providing wrong information 7905
- [Broker] Don't fail the health check request when trying to delete the previous subscription 7906
- [Broker] Add configuration to set number of channels per bookie 7910
- [Broker] Fix publish buffer of one ServerCnx calculated multi-times when check broker's publish buffer 7926
- [Broker] Add some logging to improve Authentication debugging and Fix typos in code "occured" -> "occurred" 7934
- [Broker] Fix NPE when acknowledge messages at the broker side 7937
- [Broker] Fix the wrong issuer url concatenate 7980
- [Broker] Upgrade the snakeyaml version to 1.26 7994
- [Broker] Exclude vertx from bookkeeper-http package 7997
- [Broker] Check null point before setting auto read 7999
- [Broker] Fix IndexOutOfBoundsException in the KeyShared subscription when dispatching messages to consumers 8024
- [Broker] Upgrade jetty-util version to 9.4.31 8035
- [Broker] Add replicated check to checkInactiveSubscriptions 8066
- [Broker] Add get-last-message-id admin for v1 api 8081
- [Broker] Fix client lookup hangs when broker restarts 8101
- [Broker] Should not cache the owner that does not belong to current server 8111
- [Broker] Support to specify multi ipv6 hosts in brokerServiceUrl 8120
- [Broker] Intercept messages to consumers and add intercept exception 8129
- [Broker] Add ChannelFutures utility class to pulsar-common 8137
- [Broker] Support Disable Replicated Subscriptions 8144
- [Broker] Fix error code returned to client when service unit is not ready 8147
- [Broker] Skip intercepting multipart requests 8156
- [Broker] Enable intercept filters only when interceptors are configured 8157
- [Broker] Clean inactive non-persistent subscriptions 8166
- [Broker] Add a new state for namespace-level TTL 8178
- [Broker] Fix peek messages failed with subscriptionName not exist 8182
- [Broker] Fix pulsar service close exception 8197
- [Broker] Use ThreadPoolExecutor instead of EventLoop 8208
- [Broker] Close ZK connections at end of metadata setup 8228
- [Broker] Delete associated ledgers before deleting cluster metadata 8244
- [Broker] Fix stuck lookup operations when the broker is starting up 8273
- [Broker] Fix Broker enters an infinite loop in ManagedLedgerImpl.asyncReadEntries 8284
- [Broker] Fix message TTL on Key_Shared subscription and Fix ordering issue when replay messages 8292
- [Broker] Fix race condition in updating readPosition in ManagedCursorImpl 8299
- [Broker] Refresh ZooKeeper-data cache in background to avoid deadlock and blocking IO on ZK thread 8304
- [Broker] Upgrade hdfs2 version to 2.8.5 8319
- [Broker] Upgrade solr version to 8.6.3 8328
- [Broker] Fix deadlock that occurred during topic ownership check 8406
Proxy
- [Proxy] Add advertisedAddress config field to ProxyConfiguration 7542
- [Proxy] Fix deadlock in pulsar proxy 7690
- [Proxy] Handle NPE while updating proxy stats 7766
- [Proxy] Fix the null exception when starting the proxy service 8019
- [Proxy] Add proxy plugin interface to support user defined additional servlet 8067
Pulsar SQL
- [Pulsar SQL] Upgrade Presto version to 332 7194
- [Pulsar SQL] Replace com.ning.asynchttpclient with org.asynchttpclient 8099
Pulsar Functions
- [Pulsar Functions] During Function update, cleanup should only happen for temp files that were generated 7201
- [Pulsar Functions] Have metadata tailer use its own thread for processing 7211
- [Pulsar Functions] Allow kubernetes runtime to customize function instance class path 7844
- [Pulsar Functions] SinkRecord adds an overridden method 8038
- [Pulsar Functions] Set dryrun of KubernetesRuntime is null 8064
- [Pulsar Functions] Allow disabling forwarding source message properties 8158
- [Pulsar Functions] Missed dryRun on maintenance of secrets 8286
Pulsar Perf
- [Pulsar Perf] Support setting message key 7989
- [Pulsar Perf] Make pulsar-perf ioThread number configurable 8090
Pulsar Admin
- [Pulsar Admin] Support initial namespace of the cluster without startup the broker 7434
- [Pulsar Admin] Fix some params on consumer broken by #4400 (regex, initialSouscriptionPosition) 7795
- [Pulsar Admin] Return more informative error message when trying to create subscription on non-persistent through Rest API or pulsar-admin CLI 7831
- [Pulsar Admin] Add cli command to get last message Id 8082
- [Pulsar Admin] Support delete all data associated with a cluster 8133
- [Pulsar Admin] Support delete schema ledgers when delete topics 8167
- [Pulsar Admin] Add command to delete a cluster's metadata from ZK 8169
- [Pulsar Admin] Support reset cursor to a batch index for Pulsar Admin 8329