Skip to content

Commit 707ee6c

Browse files
priyanshu-ctdspriyanshu-ctds
authored
Luna Streaming 3.1.4.18 (#220)
1 parent c269804 commit 707ee6c

File tree

1 file changed

+134
-0
lines changed

1 file changed

+134
-0
lines changed

‎Luna_Streaming_3.1_Release_Notes.md

Lines changed: 134 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,140 @@ both methods follow the same packaging patterns.
7575

7676
# Releases
7777

78+
## Luna Streaming Distribution 3.1 4.18
79+
This maintenance release of the DataStax Luna Streaming Distribution for 3.1 which includes important stability and security updates for Luna Streaming, as well as for the various connectors packaged alongside it, such as sinks, sources, functions, protocol extensions, proxy extensions, filters, and client extensions.
80+
81+
### Most notable commits
82+
* [86a5ff5ed46](https://github.com/datastax/pulsar/commit/86a5ff5ed46) Release 3.1.4.18
83+
* [3f69c8d9cd1](https://github.com/datastax/pulsar/commit/3f69c8d9cd1) Revert "[fix][broker]Fix thread safety issues in BucketDelayedDeliveryTracker with StampedLock optimistic reads (#24542)"
84+
* [af0cf6715d1](https://github.com/datastax/pulsar/commit/af0cf6715d1) [fix][client][branch-4.0] Partitioned topics are unexpectedly created by client after deletion (#24554) (#24571)
85+
* [b3508cefdbf](https://github.com/datastax/pulsar/commit/b3508cefdbf) [fix][test] fix flaky GrowableArrayBlockingQueueTest.testPollBlockingThreadsTermination (#24576)
86+
* [5d1a856ee4d](https://github.com/datastax/pulsar/commit/5d1a856ee4d) [fix][broker] Fix ManagedCursor state management race conditions and lifecycle issues (#24569)
87+
* [2ef2e4b15d9](https://github.com/datastax/pulsar/commit/2ef2e4b15d9) [improve][client] Terminate consumer.receive() when consumer is closed (#24550)
88+
* [c8a35e2c7cb](https://github.com/datastax/pulsar/commit/c8a35e2c7cb) fix cherry-pick: corrected imports and removed unwanted ones
89+
* [be32a296c86](https://github.com/datastax/pulsar/commit/be32a296c86) [fix][sec] Upgrade Kafka connector and clients version to 3.9.1 to address CVE-2025-27818 (#24564)
90+
* [3853b407c48](https://github.com/datastax/pulsar/commit/3853b407c48) [improve][build] replace org.apache.commons.lang to org.apache.commons.lang3 (#24473)
91+
* [f4f5ce5374c](https://github.com/datastax/pulsar/commit/f4f5ce5374c) [fix][broker] Fix maxTopicsPerNamespace might report a false failure (#24560)
92+
* [8171c687e5f](https://github.com/datastax/pulsar/commit/8171c687e5f) [fix][test]fix flaky test BrokerServiceAutoTopicCreationTest.testDynamicConfigurationTopicAutoCreationPartitioned (#24505)
93+
* [df2d8ec62c8](https://github.com/datastax/pulsar/commit/df2d8ec62c8) [fix] Prevent IllegalStateException: Field 'message' is not set (#24472)
94+
* [0a46b222c6a](https://github.com/datastax/pulsar/commit/0a46b222c6a) [fix][broker]Fix thread safety issues in BucketDelayedDeliveryTracker with StampedLock optimistic reads (#24542)
95+
* [5dbad4e7831](https://github.com/datastax/pulsar/commit/5dbad4e7831) [fix][broker] Fix Broker OOM due to too many waiting cursors and reuse a recycled OpReadEntry incorrectly (#24551)
96+
* [55676cf0a92](https://github.com/datastax/pulsar/commit/55676cf0a92) [fix][broker] Fix deduplication replay might never complete for exceptions (#24511)
97+
* [88ee67b2285](https://github.com/datastax/pulsar/commit/88ee67b2285) [fix][ml] Fix the possibility of message loss or disorder when ML PayloadProcessor processing fails (#24522)
98+
* [e76eefdd4d5](https://github.com/datastax/pulsar/commit/e76eefdd4d5) [fix][test][branch-3.0] Correct topic policy loading logic and improve related tests (#24451)
99+
* [17f1275d498](https://github.com/datastax/pulsar/commit/17f1275d498) [improve][test] Remove EntryCacheCreator from ManagedLedgerFactoryImpl (#24552)
100+
* [978af706dac](https://github.com/datastax/pulsar/commit/978af706dac) fix cherry-pick: fixed check style issues and modified code as per existing class
101+
* [f59b6e967ad](https://github.com/datastax/pulsar/commit/f59b6e967ad) [improve][io] Add support for the complete KinesisProducerConfiguration in KinesisSinkConfig (#24489)
102+
* [26fd41b90fc](https://github.com/datastax/pulsar/commit/26fd41b90fc) [fix][sec] Upgrade pulsar-function-go dependencies to address CVE-2025-22868 (#24547)
103+
* [1724692c388](https://github.com/datastax/pulsar/commit/1724692c388) [improve] Upgrade pulsar-client-python to 3.8.0 in Docker image (#24544)
104+
* [c52a4c0d8d2](https://github.com/datastax/pulsar/commit/c52a4c0d8d2) [fix][broker] Fix exclusive producer creation when last shared producer closes (#24516)
105+
* [c522e8bd624](https://github.com/datastax/pulsar/commit/c522e8bd624) [fix][broker] Fix duplicate increment of ADD_OP_COUNT_UPDATER in OpAddEntry (#24506)
106+
* [0bd2df4b3f3](https://github.com/datastax/pulsar/commit/0bd2df4b3f3) [fix][broker] Fix matching of topicsPattern for topic names which contain non-ascii characters (#24543)
107+
* [c56eb8953ca](https://github.com/datastax/pulsar/commit/c56eb8953ca) [fix][client] Close orphan producer or consumer when the creation is interrupted (#24539)
108+
* [fb828f0cc07](https://github.com/datastax/pulsar/commit/fb828f0cc07) [fix][client] Fix ClientCnx handleSendError NPE (#24517)
109+
* [053d5415c9f](https://github.com/datastax/pulsar/commit/053d5415c9f) [fix][ml] Fix asyncReadEntries might never complete if empty entries are read from BK (#24515)
110+
* [5789899f9a6](https://github.com/datastax/pulsar/commit/5789899f9a6) fix cherry-pick: deleted empty file
111+
* [1b55f20b7d8](https://github.com/datastax/pulsar/commit/1b55f20b7d8) fix cherry-pick: imported assertTrue
112+
* [cd407df7500](https://github.com/datastax/pulsar/commit/cd407df7500) [improve][broker][branch-3.0] Upgrade BookKeeper to 4.16.7
113+
* [9adf0378fa3](https://github.com/datastax/pulsar/commit/9adf0378fa3) [fix][ci][branch-3.0] Fix issue in GitHub Actions when /etc/docker/daemon.json file doesn't exist
114+
* [bdfb3a759ff](https://github.com/datastax/pulsar/commit/bdfb3a759ff) [improve][misc] Optimize topic list hashing so that potentially large String allocation is avoided (#24525)
115+
* [2e8904c45e2](https://github.com/datastax/pulsar/commit/2e8904c45e2) [fix][client] Fix issue in auto releasing of idle connection with topics pattern consumer (#24528)
116+
* [03b4b4c13bf](https://github.com/datastax/pulsar/commit/03b4b4c13bf) [improve][test][branch-3.0] Backport MockedPulsarServiceBaseTest.registerCloseable to branch-3.0
117+
* [d45c6d0e353](https://github.com/datastax/pulsar/commit/d45c6d0e353) [fix][proxy] Fix default value of connectionMaxIdleSeconds in Pulsar Proxy (#24529)
118+
* [1bb0bc14283](https://github.com/datastax/pulsar/commit/1bb0bc14283) [fix][client] NPE in MultiTopicsConsumerImpl.negativeAcknowledge (#24476)
119+
* [57b319f1497](https://github.com/datastax/pulsar/commit/57b319f1497) [fix][proxy] Fix proxy OOM by replacing TopicName with a simple conversion method (#24465)
120+
* [f107d158e34](https://github.com/datastax/pulsar/commit/f107d158e34) [fix][test] Move ExtensibleLoadManagerImplTest to flaky tests (#22495)
121+
* [b9471959779](https://github.com/datastax/pulsar/commit/b9471959779) [fix][test] Fix flaky test SimpleProducerConsumerStatTest#testPartitionTopicStats (#21642)
122+
* [92441847c3e](https://github.com/datastax/pulsar/commit/92441847c3e) [improve][broker]Rmove unused imports
123+
* [8353108572c](https://github.com/datastax/pulsar/commit/8353108572c) [fix][broker] Fix the non-persistenttopic's replicator always get error "Producer send queue is full" if set a small value of the config replicationProducerQueueSize (#24424)
124+
* [fee35e15add](https://github.com/datastax/pulsar/commit/fee35e15add) [fix][broker]excessive replication speed leads to error: Producer send queue is full (#24189)
125+
* [1b99324c8fd](https://github.com/datastax/pulsar/commit/1b99324c8fd) [Fix][broker] Limit replication rate based on bytes (#22674)
126+
* [4c4de8433aa](https://github.com/datastax/pulsar/commit/4c4de8433aa) [fix][broker] Fix ack hole in cursor for geo-replication (#20931)
127+
* [626d5afa0ec](https://github.com/datastax/pulsar/commit/626d5afa0ec) [fix][txn] Fix negative unacknowledged messages in transactions by ensuring that the batch size is added into CommandAck (#24443)
128+
129+
130+
### `lunastreaming-all` distribution
131+
<details><summary>CLI extensions</summary>
132+
133+
| Name | Description | Version | File |
134+
| ---- | ----------- | ------- | ---- |
135+
| [cassandra-cdc](https://pulsar.apache.org/docs/io-connectors) | Cassandra CDC - Pulsar Admin Custom Commands | 2.3.2 | pulsar-cassandra-admin-2.3.2-nar.nar |
136+
| [jms](https://pulsar.apache.org/docs/io-connectors) | Starlight for JMS - Pulsar Admin Custom Commands | 6.0.5 | pulsar-jms-admin-6.0.5-nar.nar |
137+
</details>
138+
139+
<details><summary>Filters</summary>
140+
141+
| Name | Description | Version | File |
142+
| ---- | ----------- | ------- | ---- |
143+
| [jms](https://pulsar.apache.org/docs/io-connectors) | Starlight for JMS - support for server side filters | 6.0.5 | pulsar-jms-6.0.5-nar.nar |
144+
</details>
145+
146+
<details><summary>Protocol handlers</summary>
147+
148+
| Name | Description | Version | File |
149+
| ---- | ----------- | ------- | ---- |
150+
| [kafka](https://github.com/datastax/starlight-for-kafka) | Kafka Protocol Handler | 3.1.0.4 | pulsar-protocol-handler-kafka-3.1.0.4.nar |
151+
| [rabbitmq](https://github.com/datastax/starlight-for-rabbitmq) | Starlight for RabbitMQ Proxy Extension | 2.10.1.1 | starlight-rabbitmq-2.10.1.1.nar |
152+
| [rabbitmq](https://github.com/datastax/starlight-for-rabbitmq) | Starlight for RabbitMQ Proxy Extension | 2.10.1.1 | starlight-rabbitmq-2.10.1.1.nar |
153+
</details>
154+
155+
<details><summary>Proxy extensions</summary>
156+
157+
| Name | Description | Version | File |
158+
| ---- | ----------- | ------- | ---- |
159+
| [rabbitmq](https://github.com/datastax/starlight-for-rabbitmq) | Starlight for RabbitMQ Proxy Extension | 2.10.1.1 | starlight-rabbitmq-2.10.1.1.nar |
160+
| [kafka](https://github.com/datastax/starlight-for-kafka) | Kafka Proxy Extension | 3.1.0.4 | pulsar-kafka-proxy-3.1.0.4.nar |
161+
| [rabbitmq](https://github.com/datastax/starlight-for-rabbitmq) | Starlight for RabbitMQ Proxy Extension | 2.10.1.1 | starlight-rabbitmq-2.10.1.1.nar |
162+
</details>
163+
164+
<details><summary>Sinks</summary>
165+
166+
| Name | Description | Version | File |
167+
| ---- | ----------- | ------- | ---- |
168+
| [cassandra-enhanced](https://github.com/datastax/pulsar-sink) | A DataStax Pulsar Sink to load records from Pulsar topics to Apache Cassandra(R) or DataStax Enterprise(DSE) | 1.6.14 | cassandra-enhanced-pulsar-sink-1.6.14-nar.nar |
169+
| [cloud-storage](https://github.com/streamnative/pulsar-io-cloud-storage) | Writes data into cloud storage | 3.2.4 | pulsar-io-cloud-storage-3.2.4.nar |
170+
| [data-generator](https://pulsar.apache.org/docs/io-connectors) | Test data generator source | 3.1.4.18 | pulsar-io-data-generator-3.1.4.18.nar |
171+
| [elastic_search](https://pulsar.apache.org/docs/io-connectors) | Writes data into Elastic Search | 3.1.4.18 | pulsar-io-elastic-search-3.1.4.18.nar |
172+
| [http](https://pulsar.apache.org/docs/io-connectors) | Writes data to an HTTP server (Webhook) | 3.1.4.18 | pulsar-io-http-3.1.4.18.nar |
173+
| [jdbc-clickhouse](https://pulsar.apache.org/docs/io-connectors) | JDBC sink for ClickHouse | 3.1.4.18 | pulsar-io-jdbc-clickhouse-3.1.4.18.nar |
174+
| [jdbc-mariadb](https://pulsar.apache.org/docs/io-connectors) | JDBC sink for MariaDB | 3.1.4.18 | pulsar-io-jdbc-mariadb-3.1.4.18.nar |
175+
| [jdbc-openmldb](https://pulsar.apache.org/docs/io-connectors) | JDBC sink for OpenMLDB | 3.1.4.18 | pulsar-io-jdbc-openmldb-3.1.4.18.nar |
176+
| [jdbc-postgres](https://pulsar.apache.org/docs/io-connectors) | JDBC sink for PostgreSQL | 3.1.4.18 | pulsar-io-jdbc-postgres-3.1.4.18.nar |
177+
| [jdbc-sqlite](https://pulsar.apache.org/docs/io-connectors) | JDBC sink for SQLite | 3.1.4.18 | pulsar-io-jdbc-sqlite-3.1.4.18.nar |
178+
| [kafka](https://pulsar.apache.org/docs/io-connectors) | Kafka source and sink connector | 3.1.4.18 | pulsar-io-kafka-3.1.4.18.nar |
179+
| [kinesis](https://pulsar.apache.org/docs/io-connectors) | Kinesis connectors | 3.1.4.18 | pulsar-io-kinesis-3.1.4.18.nar |
180+
| [lakehouse](https://pulsar.apache.org/docs/io-connectors) | Lakehouse connectors | 3.3.3.1 | pulsar-io-lakehouse-3.3.3.1-cloud.nar |
181+
| [snowflake](https://github.com/datastax/snowflake-connector) | Snowflake Connector | 0.2.1 | pulsar-snowflake-connector-0.2.1.nar |
182+
</details>
183+
184+
<details><summary>Sources</summary>
185+
186+
| Name | Description | Version | File |
187+
| ---- | ----------- | ------- | ---- |
188+
| [cassandra-source](https://github.com/datastax/cdc-for-apache-cassandra) | Read data from Cassandra | 2.3.2 | pulsar-cassandra-source-2.3.2.nar |
189+
| [data-generator](https://pulsar.apache.org/docs/io-connectors) | Test data generator source | 3.1.4.18 | pulsar-io-data-generator-3.1.4.18.nar |
190+
| [debezium-mongodb](https://pulsar.apache.org/docs/io-connectors) | Debezium MongoDb Source | 3.1.4.18 | pulsar-io-debezium-mongodb-3.1.4.18.nar |
191+
| [debezium-mssql](https://pulsar.apache.org/docs/io-connectors) | Debezium Microsoft SQL Server Source | 3.1.4.18 | pulsar-io-debezium-mssql-3.1.4.18.nar |
192+
| [debezium-mysql](https://pulsar.apache.org/docs/io-connectors) | Debezium MySql Source | 3.1.4.18 | pulsar-io-debezium-mysql-3.1.4.18.nar |
193+
| [debezium-oracle](https://pulsar.apache.org/docs/io-connectors) | Debezium Oracle Source | 3.1.4.18 | pulsar-io-debezium-oracle-3.1.4.18.nar |
194+
| [debezium-postgres](https://pulsar.apache.org/docs/io-connectors) | Debezium Postgres Source | 3.1.4.18 | pulsar-io-debezium-postgres-3.1.4.18.nar |
195+
| [kafka](https://pulsar.apache.org/docs/io-connectors) | Kafka source and sink connector | 3.1.4.18 | pulsar-io-kafka-3.1.4.18.nar |
196+
| [kinesis](https://pulsar.apache.org/docs/io-connectors) | Kinesis connectors | 3.1.4.18 | pulsar-io-kinesis-3.1.4.18.nar |
197+
| [lakehouse](https://pulsar.apache.org/docs/io-connectors) | Lakehouse connectors | 3.3.3.1 | pulsar-io-lakehouse-3.3.3.1-cloud.nar |
198+
</details>
199+
200+
<details><summary>Functions</summary>
201+
202+
| Name | Description | Version | File |
203+
| ---- | ----------- | ------- | ---- |
204+
| [ai-tools](https://pulsar.apache.org/docs/io-connectors) | Generative AI tools | 3.2.1 | pulsar-ai-tools-3.2.1.nar |
205+
| [transforms](https://pulsar.apache.org/docs/io-connectors) | Transformation function | 3.2.1 | pulsar-transformations-3.2.1.nar |
206+
</details>
207+
208+
### Environment (Connectors, Protocol Handlers, Proxy Extensions, extra libraries)
209+
See the [environment variables](https://github.com/riptano/pulsar-distro/blob/release/ls31/build.json) used for the build.
210+
211+
78212
## Luna Streaming Distribution 3.1 4.17
79213
This maintenance release of the DataStax Luna Streaming Distribution for 3.1 which includes important stability and security updates for Luna Streaming, as well as for the various connectors packaged alongside it, such as sinks, sources, functions, protocol extensions, proxy extensions, filters, and client extensions.
80214

0 commit comments

Comments
 (0)