All Versions
43
Latest Version
Avg Release Cycle
151 days
Latest Release
43 days ago

Changelog History
Page 3

  • v2.6.2-candidate Changes

    November 06, 2020

    2020-11-02

  • v2.6.1 Changes

    August 21, 2020

    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
    • 0️⃣ [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
    • 0️⃣ [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

  • v2.6.1-candidate

    August 14, 2020

  • v2.6.0 Changes

    June 17, 2020

    2.6.0 — 2020-06-17

    🔋 Features
    PIPs
    • 👍 [PIP-37] Large message size support #4400
    • [PIP-39] Namespace change events (System Topic) #4955
    • 📇 [PIP-45] Switch ManagedLedger to use MetadataStore interface #5358
    • [PIP 53] Contribute DotPulsar to Apache Pulsar
    • 👍 [PIP-54] Support acknowledgment at batch index level #6052
    • 👍 [PIP-58] Support consumers set custom message retry delay #6449
    • 👍 [PIP-60] Support SNI routing to support various proxy-server #6566
    • [PIP-61] Advertise multiple addresses #6903
    • 👍 [PIP-65] Adapting Pulsar IO Sources to support Batch Sources #7090
    Broker
    • [Broker] Add threshold shedder strategy and metrics exporter for loadbalancer #6772
    • [Broker] Add consistent hashing in the Key_Shared distribution #6791
    • 🛠 [Broker] Fixed ordering issue in KeyShared subscription dispatcher when adding consumer #7106 #7108 #7188
    • 👍 [Broker] Add support for key hash range reading in Key_Shared subscription #5928
    • [Broker] Allow for schema reader and writer registration on SchemaDefinition #6905
    • 👍 [Broker] Support use null key and null value in KeyValue Schema #7139
    • 👍 [Broker] Support multiple pulsar clusters to use the same bk cluster #5985
    • [Broker] Add a flag to skip broker shutdown on transient OOM #6634
    • 🔧 [Broker] Make zookeeper cache expiry time configurable #6668
    • [Broker] Check replicator periodically to avoid issue due to zookeeper missing watch #6674
    • [Broker] Expose managedLedgerCache, managedLedger, loadBalance metrics to Prometheus #6705
    • ⚡️ [Broker] Optimize consumer fetch messages in case of batch message #6719
    • 🔧 [Broker] Add configuration to limit max partitions for a partitioned topic #6794
    • 0️⃣ [Broker] Change default FlushEntryLogBytes to 256MB to improve bookie io throughput #6915
    • [Broker] Introduce precise topic publish rate limiting #7078
    • [Broker] Expose new entries check delay in the broker.conf 7154
    • [Broker] Add broker interceptor for intercepting all Pulsar command and REST API requests #7143
    • 👀 [Broker] Only close active consumer for Failover subscription when seek() #7141
    • [Broker] Allow to delete topics that are failing to recover #7131
    • 👍 [Broker] Support set netty max frame size in bookkeeper.conf #7116
    • [Broker] Trigger rollover when meeting maxLedgerRolloverTimeMinutes #7111
    • 🛠 [Broker] Cap the dispatcher batch size in bytes to fixed max #7097
    • 👍 [Broker] Support specify managedLedgerMaxSizePerLedgerMbytes in broker.conf #7085
    • [Broker] Allow to grant permissions when the authorization is disabled #7074
    • [Broker] Add messages and bytes counter stats to broker-stats/topics #7045
    • [Broker] Expose new entries check delay in the broker.conf #7154
    Function
    • 👍 [Function] Built-in functions support #6895
    • [Function] Add Go Function heartbeat (and gRPC service) for production usage #6031
    • [Function] Add custom property option to functions #6348
    • 🔧 [Function] Separate TLS configuration of function worker and broker #6602
    • 🏗 [Function] Added ability to build consumers in functions and sources #6954
    • 👍 [Function] Support DLQ on sources and sinks #7032
    Pulsar SQL
    • 👍 [SQL] KeyValue schema support #6325
    • 👍 [SQL] Multiple version schema support #4847
    • [SQL] Fix presto SQL does not start metrics service before queue execute #7030
    Pulsar IO
    • ➕ Added ability for sources to publish messages on their own #6941
    • [RabbitMQ] Allow routing key per message to RabbitMQ sink connector #5890
    • [RabbitMQ] Add passive config options #6679
    • ⬆️ [debezium] Upgrade from v0.10.0-Final to v1.0.0-Final #5972
    • 👍 [debezium] Support avro schema for debezium connector #6034
    • 👍 [influxdb2] Add support for influxdb2 in pulsar-influxdb-sink #6601
    • [jdbc] Add jdbc sinks: postgres, mariadb, clickhouse #6835
    Pulsar Proxy
    • [Proxy] Add REST API to get connection and topic stats #6473
    • [Proxy] Add advertised address option #6942
    • [Proxy] Add proxyLogLevel into config #6948
    Clients
    • [Java Client] Use pure-java Air-Compressor instead of JNI based libraries #5390
    • [Java Client] Change the time unit of patternAutoDiscoveryPeriod to seconds #5950
    • 👍 [Java Client] Support waiting for inflight messages while closing producer #6648
    • 👍 [Java Client] Add support to load TLS certs/key dynamically from input stream #6760
    • 👻 [Java Client] Support return sequence ID when throwing Exception for async send message #6825
    • 0️⃣ [Java Client] Change the default value of maxLookupRedirects of Java client to 20 #7126
    • [Java Client] Limit the number of times lookup requests are redirected #7096
    • 👀 [CPP Client] Support seek by time on partitioned topic #7198
    • [CPP Client] Refresh authentication credentials #7070
    • [CPP Client] Fix Result can't be serialized to string inside the library #7034
    • 👍 [CPP Client] Support zstd and Snappy compression to C API #7014
    • [Python Client] Add deliver_at and deliver_after for the producer #6737
    Admin
    • 👍 [Admin] Support delete inactive topic when subscriptions caught up #6077
    • 🔧 [Admin] Add configuration to disable auto-creation of subscriptions #6456
    • [Admin] Add maxUnackedMessagesPerSubscription and maxUnackedMessagesPerConsumer on namespaces policies #5936
    • 👍 [Admin] Support get a message by message ID in pulsar-admin #6331
    • 👍 [Admin] Support delete subscription forcefully #6383
    • [Admin] Add subscribe initial position for consumer CLI #6442
    • 👍 [Admin] Support to get managed ledger info of a partitioned topic #6532
    • 👍 [Admin] Support compact all partitions of a partitioned topic #6537
    • 👍 [Admin] Support multi-hosts in PulsarAdmin #6547
    • 👍 [Admin] Support to get internal stats for a partitioned topic #6624
    • 👍 [Admin] Support enable or disable subscription auto-creation at namespace level #6637
    • [Admin] Enable to set the subscription expiration time for each namespace #6851
    🛠 Fixes
    • 🛠 [Broker] Fixed increasing number of partitions with attached readers #7077
    • [Broker] Make ZkBookieRackAffinityMapping work as expected #6917
    • [Broker] Fix backlog and backlog size stats keeps growing #7082
    • [Java Client] Fix connection leak #6524
    • [Java Client] Fix message id compare between MessageId and BatchMessageId #6621
    • [Java Client] Fix memory leak when create producer with not exsits topic #7120 #7124
    • [Java Client] Fix duplicated messages sent to dead letter topic #7021
    • [CPP Client] Fix deadlock of consumer for topics auto discovery #7206
    • [Managed Ledger] Fix NPE on opening non-durable cursors on an empty managed ledger #7133
    • 📜 [Websocket] Fix incorrect topic URL parse #6630
    • [Pulsar SQL] Fix problem with multiple zookeeper address #6947
    • 🐳 [Docker] Do not apply env values to pulsar_env.sh and bkenv.sh implicitly 6579

  • v2.6.0-candidate

    June 09, 2020

  • v2.5.2 Changes

    May 19, 2020

    2.5.2 — 2020-05-19

    🛠 Fixes and Enhancements
    Broker
    • [Broker] Implement AutoTopicCreation by namespace level override #6471
    • [Broker] Add custom deletionLag and threshold for offload policies per namespace #6422
    • [Broker] Invalidate managed ledgers zookeeper cache instead of reloading on watcher triggered #6659
    • [Broker] Retention policy should be respected when there is no traffic #6676
    • 🛠 [Broker] Fixed double delete on a namespace #6713
    • [Broker] fix get batch message from http response, only get the first message#6715
    • [Broker] Fix Deadlock by Consumer and Reader#6728
    • [Broker] avoid backpressure by skipping dispatching if consumer channel is not writable #6740
    • 🚀 [Broker] fix when producing encrypted messages, MessageMetadata objects are not released after they are created. #6745
    • [Broker] Bump netty version to 4.1.48.Final #6746
    • ⏱ [Broker] Increase timeout for loading topics #6750
    • [Broker] Fix wrong cursor state for cursor without consumer #6766
    • 🐎 [Broker] change nondurable cursor to active to improve performance #6769
    • [Broker] register loadbalance znode should attempt to wait until session expired #6788
    • [Broker] Fix some empty message related problems in the compacted topic. #6795
    • [Broker] Avoid creating partitioned topic for partition name #6846
    • 👍 [Broker] Add Tls with keystore type config support #6853
    • [Broker] fix consumer stuck when batchReceivePolicy maxNumMessages > maxReceiverQueueSize #6862
    • [Broker] use originalAuthMethod on originalAuthChecker in Proxy Authentication #6870
    • [Broker] Close producer when the topic does not exists. #6879
    • [Broker] Handle all exceptions from topic.addProducer #6881
    • [Broker] fix topicPublishRateLimiter not effective after restart broker #6893
    • [Broker] Expose pulsar_out_bytes_total and pulsar_out_messages_total for namespace/subscription/consumer. #6918
    • 0️⃣ [Broker] Policy ttlDurationDefaultInSeconds not applying #6920
    • [Broker] Fix pulsar admin thread number explode bug. #6940
    Pulsar Schema
    • 📜 [Schema] Fix long field parse in GenricJsonRecord #6622
    • [Schema] Fix the leak of cursor reset if message encode fails in Avro schema. #6695
    • [Schema] fix Get schema by version can get the deleted schema info #6754 #6754
    • [Schema] Fix serialization of enums with json/avro schemas in python #6808
    • 👍 [Schema] Pulsar SQL Support Avro Schema ByteBuffer Type #6925
    CPP Client
    • ⚡️ [CPP Client] Auto update topic partitions #6732
    • [CPP Client] Subscription InitialPosition is not correctly set on regex consumers. #6810
    • 0️⃣ [CPP Client] Fix message id is always the default value in send callback #6812
    • [CPP Client] Fix message id error if messages were sent to a partitioned topic #6938
    Python Client
    • [Python Client] Fix Python function protobuf missing field#6641
    Pulsar Functions
    • 👍 [Functions] Support function with format: Function<I, CompletableFuture>#6684
    • [Functions] Function endpoint admin/v3/functions/{tenant}/{namespace} always returns 404 #6767
    • [Functions] Ensure that all dangling consumers are cleaned up during failures #6778
    • [Functions] Fix localrunner netty dependency issue #6779
    • ⚡️ [Functions] Fix SerDe validation of function's update #6888
    Tiered Storage
    • [Tiered Storage] Extract common SerDe method in tiered storage to managed-ledger module #6533
    • [Tiered Storage] Make SchemaStorage accessible in Offloader #6567
    • [Tiered Storage] Avoid prefetch too much data causing OutOfMemory, when offloading data to HDFS #6717
    Pulsar IO
    • [IO] JDBC sink does not handle null in schema #6848

  • v2.5.2-candidate

    May 13, 2020

  • v2.5.1 Changes

    May 11, 2020

    2.5.1 — 2020-04-20

    🔋 Features
    • PIP-55: Refresh Authentication Credentials #6074
    • 👍 Namespace level support offloader #6183
    • ⬆️ Upgrade Avro to 1.9.1 #5938
      • Avro 1.9.1 enables the JSR310 datetimes by default, which might introduce some regression problems if users use generated source code by Avro compiler 1.8.x and contains datetimes fields. It's better to use Avro 1.9.x compiler to recompile.
    • 👌 Support unload all partitions of a partitioned topic #6187
    • 👌 Supports evenly distribute topics count when splits bundle #6241
    • 👍 KeyValue schema support for pulsar sql #6325
    • ⬆️ Bump netty version to 4.1.45.Final #6424
    • 👌 Support BouncyCastle FIPS provider #6588
    • 👌 Improve Key_Shared subscription message dispatching performance. #6647
    • ➕ Add JSR310 logical type conversion. #6704
    • 🔧 Introduce maxMessagePublishBufferSizeInMB configuration to avoid broker OOM #6178
    🛠 Fixes
    Broker
    • 🛠 [Broker] Fixed NPE occurs when getting partitioned topic stats #6060
    • 🛠 [Broker] Fixed zero queue consumer message redelivery #6076
    • 🛠 [Broker] Fixed message redelivery for zero queue consumer while using async api to receive messages #6090
    • 🛠 [broker] Fixed bug that backlog message that has not yet expired could be deleted due to TTL #6211
    • 🚚 [Broker] Remove problematic semicolon from conf #6303
    • 🛠 [Broker] Fixed broker to specify a list of bookie groups #6349
    • 🛠 [Broker] Fixed create consumer on partitioned topic while disable topic auto creation #5572
    • [Broker] Fix maven broken link #6068
    • 🛠 [Broker] Fixed java code errors reported by lgtm. #6398
    • 🛠 [Broker] Fixed memory leak when running topic compaction. #6485
    • 🛠 [Broker] Fixed admin getLastMessageId return batchIndex #6511
    • ⚡️ [Broker] Fixed topic with one partition cannot be updated #6560
    • 🛠 [Broker] Fixed negative un-ack messages in consumer stats #5929
    • ⚡️ [broker] Fixed bug that tenants whose allowed clusters include global cannot be created/updated #6275
    • 🛠 [Broker] Fixed log compaction for flow control/empty topic/last deletion #6237
    • ⏪ [Broker] Fixed restore clusterDispatchRate policy for compatibility #6176
    • [Broker] Fix some async method problems at PersistentTopicsBase. #6483
    • [Broker] This "earlier" message should be avoided to emit when reset cursor.#6393
    Managed Ledger
    • 🛠 [Managed Ledger] Fixed consumer received duplicated delayed messages upon restart #6404
    Pulsar Proxy
    • 🛠 [Proxy] Fixed correct name for proxy thread executor name #6460
    • 🛠 [Proxy] Fixed logging for published messages #6474
    • 👷 [Proxy] Fixed proxy routing to functions worker #6486
    Zookeeper
    • 🛠 [Zookeeper] Fixed casting in ZooKeeperCache.getDataIfPresent() #6313
    Pulsar Functions
    • 🚚 [Function] remove future.join() from PulsarSinkEffectivelyOnceProcessor #6361
    Pulsar SQL
    • ✅ [SQL] Fixed integration Pulsar SQL test failed #6279
    🔒 Security
    • 🛠 Fixed publish buffer limit does not take effect #6431
    • 🛠 Fixed the bug of authenticationData is't initialized. #6440
    Pulsar Schema
    • 🛠 [Schema] Fixed get schema version in HttpLookupService. #6193
    • 🛠 [Schema] Fixed avro schema decode error ClassCastException in Pulsar Function #6662
    • 🛠 [Schema] Fixed channel write error handling for send get raw schema request #6650
    Java client
    • 🛠 [Client] Fixed available permits may be greater than 1 even though queue size is 0. #6106
    • 🛠 [Client] Fixed broker client tls settings error #6128
    • 🛠 [Client]Fixed hasMessageAvailable() #6362
    • 🛠 [Client] Fixed duplicate key to send propertys #6390
    • 🛠 [Client] fixed deadlock on send failure #6488
    • 🛠 [Client] Fixed NPE while call getLastMessageId #6562
    • 🔧 [Client] Fixed the max backoff configuration for lookups #6444
    C++ client
    • 🍎 [C++] Fixed static linking on C++ lib on MacOS #5581
    • 🛠 [C++] Fixed memory corruption on ExecutorService destructor #6270
    • 🛠 [C++] Fixed handling of canceled timer events on NegativeAcksTracker #6272
    • 🛠 [C++] Fixed for possible deadlock when closing Pulsar client #6277
    • 🛠 [C++] Fixed Unacked Message Tracker by Using Time Partition on C++ #6391
    • 🛠 [C++] Fixed Redelivery of Messages on UnackedMessageTracker When Ack Messages . #6498
    Python Client
    • 📦 [Python Client]Fixed the enum34 package not found #6401
    Pulsar Websocket
    • 🛠 [Websocket] Fixed Websocket doesn't set the correct cluster data #6102
    🚀 Deployments
    • 🛠 [Helm] Autorecovery - Fixed could not find or load main class #6373
    • [Helm]: Start proxy pods when at least one broker pod is running #6158
    ✨ Enhancements
    Pulsar Broker
    • [Broker] close managed-ledgers before giving up bundle ownership to avoid bad zk-version #5599
    • 🌐 [Broker] Add timeout to search for web service URLs to avoid web threads getting stuck #6124
    • [Broker] Flush the potential duplicated message when add messages to a batch. #6326
    • 📇 [Broker] Avoid getting partition metadata while the topic name is a partition name. #6339
    • 🛠 [Broker] Fixed create partitioned topic with a substring of an existing topic name. #6478
    • [Broker] Do not retry on authorization failure #6577
    • ⚡️ [Broker]Handle BadVersionException thrown by updateSchemaLocator() #6683
    • 🔧 [Broker] Expose bookkeeper expose explicit lac configuration in broker.conf #5822
    • [Broker] Allow to enable/disable delayed delivery for messages on namespace #5915
    • [Broker] Prevent creation of regular topic with the same name as existing partitioned topic #5943
    • [Broker] Reset cursor with a non-exists position #6120
    • 0️⃣ [Broker] Use fully qualified hostname as default to advertise brokers #6235
    • ⏱ [broker] Timeout API calls in BrokerService #6489
    • [Broker] Start namespace service and schema registry service before start broker. #6499
    • [Broker] Disable channel auto read when publish rate or publish buffer exceeded #6550
    • [Broker] Resume some servercnx method to public #6581
    • [Broker] Enable get precise backlog and backlog without delayed messages. #6310
    • [Broker] Avoid using same OpAddEntry between different ledger handles #5942
    • [Broker] Clean up closed producer to avoid publish-time for producer #5988
    • 👍 [Broker] Support delete inactive topic when subscriptions caught up #6077
    • 🌲 [Broker] Add a message on how to make log refresh immediately when starting a component #6078
    • [Pulsar Admin] allow tenant admin to manage subscription permission #6122
    • 🌲 [Broker] Output resource usage rate to log on broker #6152
    • [Broker] Creating a topic does not wait for creating cursor of replicators #6364
    • [Broker] Stop increase unacked messages for the consumer with Exclusive/Failover subscription mode. #6558
    • [Broker] Not allow sub auto create by admin when disable topic auto create #6685
    Zookeeper
    • 👻 [Zookeeper] Close ZK before canceling future with exception #6399
    • ⬆️ [ZooKeeper] Upgrade ZooKeeper to 3.5.7 #6329
    Pulsar IO
    • ✅ [IO] Adds integration test for RabbitMQ #6033
    Pulsar Functions
    • 🚚 [Function] remove future.join() from PulsarSinkEffectivelyOnceProcessor #6361
    Stats & Monitoring
    • 🔊 [Broker] Add backlogSize in topicStats #5914
    • [Broker] Expose lastConsumedTimestamp and lastAckedTimestamp to consumer stats #6051
    • 👌 Improve backlogSize stats in the topic. #6700
    🔒 Security
    • Validate tokens for binary connections #6233
    • Create namespace failed when TLS is enabled in PulsarStandalone #6457
    • 👉 Use more granular permissions for topics #6504
    Pulsar Schema
    • [Schema] Independent schema is set for each consumer generated by topic #6356
    • [Schema] Extract an original avro schema from the "$SCHEMA" field using reflection. If it doesn't work, the process falls back generation of the schema from POJO.#6406
    • [Schema] Add verification for SchemaDefinitionBuilderImpl.java #6405
    Java client
    • [Client] Start reader inside batch result in read first message in batch. #6345
    • [Client] Stop shade snappy-java in pulsar-client-shaded #6375
    • ⏱ [Client] MultiTopics discovery is broken due to discovery task scheduled twice instead of pendingBatchReceiveTask #6407
    • [Client] Make SubscriptionMode a member of ConsumerConfigurationData #6337
    • [Client] Should set either start message id or start message from roll back duration. #6392
    • [Client] BatchReceivePolicy implements Serializable. #6423
    • 🚚 [Client] Remove duplicate cnx method #6490
    • [Client] Pulsar Java client: Use System.nanoTime() instead of System.currentTimeMillis() to measure elapsed time #6454
    • ✅ [Client] Make tests more stable by using JSONAssert equals #6247
    • [Client] make acker in BatchMessageIdImpl transient #6064
    C++ client
    • 🏁 [C++] Windows CMake corrections #6336
    • [C++] Avoid calling redeliverMessages() when message list is empty #6480
    • [C++] Improve cpp-client-lib: provide another libpulsarwithdeps.a in dep/rpm #6458
    Python Client
    • 👍 [Python Client] Support generate pulsar-client for python3.8#6741
    🚀 Deployments
    • [Helm] Explicit statement env-var 'BOOKIE_MEM' and 'BOOKIE_GC' for values-mini.yaml #6340
    • [Helm] Add missing check to dashboard-ingress #6160
    • 👉 Make kubernetes yamls for aws operational #6192
    • Ensure JVM memory and GC options are set for bookie #6201
    • 0️⃣ Default functionAuthProvider when running in k8s #6203
    Adaptors
    • [Adaptor] Skip javadoc task for pulsar-client-kafka-compact modules #5836
    • [Flink-Connector] Get PulsarClient from cache should always return an open instance #6436

  • v2.5.1-candidate

    April 15, 2020

  • v2.5.0

    January 15, 2020