All Versions
26
Latest Version
Avg Release Cycle
26 days
Latest Release
791 days ago
Changelog History
Page 3
Changelog History
Page 3
-
v2.3.2 Changes
May 31, 20192.3.2 — 2019-05-30
🛠 Fixes
- Validate admin operation on topic with authoritative parameter #4270
- 🛠 fix bug with source local run #4278
- fix cannot use size (type _Ctype_int) as type _Ctype_ulong #4212
- 🛠 Fix segfault in c++ producer #4219
- AlwaysCompatible doesn't use AlwaysSchemaValidator in 2.3.1 component/schemaregistry #4181
- Avoid potentially blocking method during topic ownership check #4190
- [pulsar-broker]Fix: client-producer can't reconnect due to failed producer-future on cnx cache #4138
- Removing # TYPE comment from topic metrics in Prometheus #4136
- 🚚 For functions metrics in prometheus also remove TYPE #4081
- 🛠 Fix: set receive queue size for sinks #4091
- 🛠 Fix: Exception when switch cluster from auth enabled to auth disabled #4069
- 🛠 Fix update cli source sink #4061
- 🛠 Fix connectors nested configs #4067
- For functions metrics, avoid having HELP #4029
- 🛠 Fix Python functions state which is completely broken #4027
- 🛠 [issue #3975] Bugfix NPE on non durable consumer #3988
- 🛠 Fix: Function auth should ignore exception because it might be anonymous user #4185
- 👷 [pulsar-function] fix worker-stats broken admin-api #4068
- 🛠 fix errors in sql doc #4030
- 🛠 Fix the swagger files generated by removing troublesome class #4024
- [pulsar-function] fix broken backward compatibility with v1-namespace while registering function #4224
- ⏪ Revert dup consumer and related code #4142
- [issue 4274][pulsar-io]Add double quotation marks for metrics with remote_cluster #4295
✨ Enhancements
- 🔧 By default, auto configure the size of Bookie read/write cache #4297
- ⬆️ Upgrade to BookKeeper 4.9.2 #4288
- 👷 [pulsar-function] support bookie authentication from function-worker #4088
- 🐎 Optimizing performance for Pulsar function archive download #4082
- 👍 allow users to update output topics for functions and sources #4092
- 👌 improve data-generator source performance #4058
- [client] Set actual topic name to partitioned consumer #4064
- 🖨 ack records in datagenerator print sink #4052
- 🔒 [security] Upgrade athenz libraries #4056
- [python client] Handle subrecords in JsonSchema encoding #4023
- [Issue 3987][pulsar-broker]Handle config is null when create tenant #4019
- ➕ Add bookkeeper client version constraint #4013
- 👌 Improve error handling for triggering function when there is a schema mismatch #3995
- 🌲 [pulsar-broker] add producer/consumer id in error-logging #3961
-
v2.3.2-candidate
May 21, 2019 -
v2.3.1 Changes
April 19, 2019🛠 Fixes
- 🛠 Fixed C++ batch acks tracker to evict message from sendList array. This was causing a slowdown in
C++ consumers #3618 - 👍 Allow publishing messages >5MB with batching (when they compress to <5MB) #3673 and #3718
- 🛠 Use at least 8 threads in Jetty thread pool. This fixed deadlocks in Jetty requests handling #3776
- 🛠 Fixed Reader.HasNext() in Go client #3764
- 🛠 Fixed increasing consumer permits after ack dedup operation. #3787
- Set the dedup cursor as "inactive" after recovery #3612
- 🛠 Fix read batching message by pulsar reader #3830
- 🛠 Fix submit function with code specified via URL #3934
- 🛠 Fixed reader reading from a partition #3960
- 🛠 Fixed issue with Authorization header missing after client gets redirected #3869
✨ Enhancements
- ➕ Added
producer.flush()
on Python #3685 - 🏗 Introduced schema builder to define schema #3682
- 👌 Support passing schema definition for JSON and AVRO schemas #3766
- Exposing InitialPosition setting in Python consumer #3714
👀 For a complete list of issues fixed, see
- 🛠 Fixed C++ batch acks tracker to evict message from sendList array. This was causing a slowdown in
-
v2.3.1-candidate Changes
April 08, 20192019-04-04
-
v2.3.0 Changes
February 21, 2019General
- 👌 Support for schema definitions in the Pulsar Python client library
- 🔒 PIP-25: Token based authentication #2888, #3067 and #3089
- 🚀 Updated to Apache BookKeeper 4.9.0
- ZStandard compression codec #3159. Note that when a producer choose Zstd compression, a consumer will need to be at least at version 2.3.0
to be able to correctly receive the messages. - 👌 Support for Java 11 #3006
- ➕ Added
Schema.AUTO_PRODUCE
type to allow to publish serialized data and validate it against the
topic schema #2685 - ➕ Added
Schema.KeyValue
to allow for schema to be validated on message keys as well as payloads. #2885 - 👌 Support TLS authentication and authorization in standalone mode #3360
- 0️⃣ When creating namespace, use local cluster by default #3571
- 🏷 Tag BookKeeper ledgers created by Pulsar with topic/subscription names for info/debug purposes
#3525 - Enabled sticky reads in BooKeeper reads to increase IO efficiency with read-ahead #3569
- Several optimization in Pulsar SQL Presto connector (#3128, #3135, #3139, #3144, #3143)
- 🔧 Configure Pulsar broker data cache automatically from JVM settings #3573
- Reuse the SSL context objects #3550
- ⚡️ Automatic schema update can be disabled through admin interface #2691
- 👌 Support Dead-Letter-Queue from WebSocket proxy #2968
- Pull-mode for WebSocket proxy #3058
- Export Jetty stats to Prometheus #2804
- ➕ Added stats for Pulsar proxy #2740
- 👍 Allow subscribers to access subscription admin-api #2981
- 🚀 Make brokers read on closest Bookie in a multi-region deployment #3171
🛠 Fixes
- 🛠 Fixed deadlock in reusing ZookKeeper event thread #3591
- 🌲 In functions log topic appender, don't set producer name #3544
- ✅ When cursor recovery encounters empty cursor ledger, fallback to latest snapshot #3487
- 🛠 Fixed C++ regex-consumer when using HTTP service URL #3407
- 🛠 Fix race condition: broker not scheduling read for active consumer #3411
Pulsar IO
- ➕ Added Debezium connector for Change-Data-Capture into Pulsar #2791
- ➕ Added MongoDB connector #3561
- ➕ Added Elastic Search connector #2546
- ➕ Added HBase sink #3368
- ➕ Added Local files connector #2869
- Report source/sink stats in Prometheus #3261
- 👍 Allow filtering in Twitter Firehose connector #3298
- Sources/Sinks can be launched using fat jars as well #3166
Pulsar Functions
- ➕ Added Kubernetes runtime #1950
- Secrets interface #2826
- Cleanup subscriptions when deleting functions #3299
- ➕ Add Windowfunction interface to functions api #3324
- 👌 Support for accessing state in Python #2714
- 👌 Support submitting Python functions as wheel file
- 👌 Support submitting Python functions as Zip file with dependencies included #3321
- ➕ Add minimum amount of resources to run setting for functions #3536
- 🛠 Fixed the behavior of Function start/stop #3477
Java client
- 🚚 Moved Pulsar v1 client API into separate artifact #3228.
🚀 Applications that are using the Pulsar v1 API, deprecated since 2.0 release, need to update the Maven dependency to use the
pulsar-client-1x
artifact instead ofpulsar-client
. Eg.\<dependency\> \<groupId\>org.apache.pulsar\</groupId\> \<artifactId\>pulsar-client-1x\</artifactId\> \<version\>2.3.0\</version\> \</dependency\>
- 🛠 Fixed shading issues with Javadoc bundled in client jars by separating the API in a different Maven module #3309
- 👌 Improve Javadocs #3592
- 👌 Support specifying multiple hosts in pulsar service url and web url #3249
- Automatically discover when partitions on a topic are increased #3513
- ➕ Added
Client.getPartitionsForTopic()
#2972 (Javadoc) - ➕ Added
Consumer.pauseMessageListener()
andConsumer.resumeMessageListener()
#2961 - ✂ Removed shading relocations for Circe-checksum and lz4 libraries, to ensure native libraries
are correctly loaded when using shaded client lib. #2191
Python client
- 🛠 Fixed
Message.properties()
#3595
Go client
- ➕ Added
Producer.flush()
to flush all outstanding messages #3469 - 👌 Support
Consumer.Seek()
#3478 - ➕ Added
Message.Topic()
#3346 - 👍 Allow to specify
SubscriptionInitPos
option inConsumerOptions
#3588 - ➕ Added TLS hostname verification #3580
- 👍 Allow to link statically against
libpulsar.a
#3488 - 🔦 Expose
Producer.LastSequenceID()
andMessage.SequenceID()
#3416
C++ client
- 0️⃣ Enable batching by default when using
sendAsync()
#2949 - 👍 Allow to specify schema info in Avro format #3354
- ➕ Added
Producer.flush()
to flush all outstanding messages #3020 - ➕ Added TLS hostname verification #2475
- 👍 Allow to specify
SubscriptionInitialPosition
#3567 - ➕ Added
Message.getTopicName()
#3326 - ➕ Added
Cosnsumer.receiveAsync()
#3389 - 🏗 Build
libpulsar.a
with all required dependencies #3488 - ✂ Removed Boost from Pulsar API headers #3374
Adaptors
- 👍 Kafka client wrapper, added support for explicit partitioning and custom partitioner #3462
- 👌 Support config
auto.offset.reset
to Pulsar KafkaConsumer #3273 - 👍 In Apache Flink connector, added support for Batch Sink API (2979#, #3039 and #3046)
- ➕ Added Java batch examples for Flink adaptor
- ➕ Added Java streaming examples for Flink adaptor
- ➕ Added Scala examples for Flink adaptor
👀 For a complete list of issues fixed, see
https://github.com/apache/pulsar/milestone/18?closed=1
Downloads at https://pulsar.apache.org/download
-
v2.3.0-candidate
February 15, 2019