This is an automated email from the ASF dual-hosted git repository. bbejeck pushed a commit to branch add_blog_additional_clean_up in repository https://gitbox.apache.org/repos/asf/kafka-site.git
commit d27cdd3e8121dafa2f6d920ca82a0481fcb0a2db Author: Bill <[email protected]> AuthorDate: Thu Jun 25 17:45:44 2026 -0400 Add blog post and fix some trailing 4.3.0 references --- content/en/43/getting-started/docker.md | 8 +++--- content/en/43/getting-started/quickstart.md | 18 ++++++------- content/en/43/kafka-connect/user-guide.md | 2 +- content/en/43/operations/tiered-storage.md | 4 +-- content/en/43/streams/developer-guide/datatypes.md | 4 +-- content/en/43/streams/developer-guide/dsl-api.md | 4 +-- content/en/43/streams/developer-guide/testing.md | 2 +- .../streams/developer-guide/write-streams-app.md | 12 ++++----- content/en/43/streams/quickstart.md | 6 ++--- content/en/43/streams/tutorial.md | 2 +- content/en/blog/releases/ak-4.3.1.md | 31 ++++++++++++++++++++++ content/en/community/downloads.md | 2 +- 12 files changed, 63 insertions(+), 32 deletions(-) diff --git a/content/en/43/getting-started/docker.md b/content/en/43/getting-started/docker.md index eaef559281..06af747125 100644 --- a/content/en/43/getting-started/docker.md +++ b/content/en/43/getting-started/docker.md @@ -33,7 +33,7 @@ type: docs Docker image can be pulled from Docker Hub using the following command: ```bash -$ docker pull apache/kafka:4.3.0 +$ docker pull apache/kafka:4.3.1 ``` If you want to fetch the latest version of the Docker image use following command: @@ -45,7 +45,7 @@ $ docker pull apache/kafka:latest To start the Kafka container using this Docker image with default configs and on default port 9092: ```bash -$ docker run -p 9092:9092 apache/kafka:4.3.0 +$ docker run -p 9092:9092 apache/kafka:4.3.1 ``` ## GraalVM Based Native Apache Kafka Docker Image @@ -56,7 +56,7 @@ NOTE: This image is experimental and intended for local development and testing Docker image can be pulled from Docker Hub using the following command: ```bash -$ docker pull apache/kafka-native:4.3.0 +$ docker pull apache/kafka-native:4.3.1 ``` If you want to fetch the latest version of the Docker image use following command: @@ -68,7 +68,7 @@ $ docker pull apache/kafka-native:latest To start the Kafka container using this Docker image with default configs and on default port 9092: ```bash -$ docker run -p 9092:9092 apache/kafka-native:4.3.0 +$ docker run -p 9092:9092 apache/kafka-native:4.3.1 ``` ## Usage guide diff --git a/content/en/43/getting-started/quickstart.md b/content/en/43/getting-started/quickstart.md index 4552e89509..63dfa1d00e 100644 --- a/content/en/43/getting-started/quickstart.md +++ b/content/en/43/getting-started/quickstart.md @@ -28,11 +28,11 @@ type: docs ## Step 1: Get Kafka -[Download](https://www.apache.org/dyn/closer.cgi?path=/kafka/4.3.0/kafka_2.13-4.3.0.tgz) the latest Kafka release and extract it: +[Download](https://www.apache.org/dyn/closer.cgi?path=/kafka/4.3.1/kafka_2.13-4.3.1.tgz) the latest Kafka release and extract it: ```bash -$ tar -xzf kafka_2.13-4.3.0.tgz -$ cd kafka_2.13-4.3.0 +$ tar -xzf kafka_2.13-4.3.1.tgz +$ cd kafka_2.13-4.3.1 ``` ## Step 2: Start the Kafka environment @@ -68,13 +68,13 @@ Once the Kafka server has successfully launched, you will have a basic Kafka env Get the Docker image: ```bash -$ docker pull apache/kafka:4.3.0 +$ docker pull apache/kafka:4.3.1 ``` Start the Kafka Docker container: ```bash -$ docker run -p 9092:9092 apache/kafka:4.3.0 +$ docker run -p 9092:9092 apache/kafka:4.3.1 ``` ### Using GraalVM Based Native Apache Kafka Docker Image @@ -82,13 +82,13 @@ $ docker run -p 9092:9092 apache/kafka:4.3.0 Get the Docker image: ```bash -$ docker pull apache/kafka-native:4.3.0 +$ docker pull apache/kafka-native:4.3.1 ``` Start the Kafka Docker container: ```bash -$ docker run -p 9092:9092 apache/kafka-native:4.3.0 +$ docker run -p 9092:9092 apache/kafka-native:4.3.1 ``` ## Step 3: Create a topic to store your events @@ -147,12 +147,12 @@ You probably have lots of data in existing systems like relational databases or In this quickstart we'll see how to run Kafka Connect with simple connectors that import data from a file to a Kafka topic and export data from a Kafka topic to a file. -First, make sure to add `connect-file-4.3.0.jar` to the `plugin.path` property in the Connect worker's configuration. For the purpose of this quickstart we'll use a relative path and consider the connectors' package as an uber jar, which works when the quickstart commands are run from the installation directory. However, it's worth noting that for production deployments using absolute paths is always preferable. See [plugin.path](../../configuration/kafka-connect-configs/#connectconfigs_ [...] +First, make sure to add `connect-file-4.3.1.jar` to the `plugin.path` property in the Connect worker's configuration. For the purpose of this quickstart we'll use a relative path and consider the connectors' package as an uber jar, which works when the quickstart commands are run from the installation directory. However, it's worth noting that for production deployments using absolute paths is always preferable. See [plugin.path](../../configuration/kafka-connect-configs/#connectconfigs_ [...] Edit the `config/connect-standalone.properties` file, add or change the `plugin.path` configuration property match the following, and save the file: ```bash -$ echo "plugin.path=libs/connect-file-4.3.0.jar" >> config/connect-standalone.properties +$ echo "plugin.path=libs/connect-file-4.3.1.jar" >> config/connect-standalone.properties ``` Then, start by creating some seed data to test with: diff --git a/content/en/43/kafka-connect/user-guide.md b/content/en/43/kafka-connect/user-guide.md index 933e925fd1..2c3ce02536 100644 --- a/content/en/43/kafka-connect/user-guide.md +++ b/content/en/43/kafka-connect/user-guide.md @@ -43,7 +43,7 @@ The first parameter is the configuration for the worker. This includes settings * `bootstrap.servers` \- List of Kafka servers used to bootstrap connections to Kafka * `key.converter` \- Converter class used to convert between Kafka Connect format and the serialized form that is written to Kafka. This controls the format of the keys in messages written to or read from Kafka, and since this is independent of connectors it allows any connector to work with any serialization format. Examples of common formats include JSON and Avro. * `value.converter` \- Converter class used to convert between Kafka Connect format and the serialized form that is written to Kafka. This controls the format of the values in messages written to or read from Kafka, and since this is independent of connectors it allows any connector to work with any serialization format. Examples of common formats include JSON and Avro. - * `plugin.path` (default `null`) - a list of paths that contain Connect plugins (connectors, converters, transformations). Before running quick starts, users must add the absolute path that contains the example FileStreamSourceConnector and FileStreamSinkConnector packaged in `connect-file-4.3.0.jar`, because these connectors are not included by default to the `CLASSPATH` or the `plugin.path` of the Connect worker (see plugin.path property for examples). + * `plugin.path` (default `null`) - a list of paths that contain Connect plugins (connectors, converters, transformations). Before running quick starts, users must add the absolute path that contains the example FileStreamSourceConnector and FileStreamSinkConnector packaged in `connect-file-4.3.1.jar`, because these connectors are not included by default to the `CLASSPATH` or the `plugin.path` of the Connect worker (see plugin.path property for examples). diff --git a/content/en/43/operations/tiered-storage.md b/content/en/43/operations/tiered-storage.md index 8fdd092fb2..c67289e530 100644 --- a/content/en/43/operations/tiered-storage.md +++ b/content/en/43/operations/tiered-storage.md @@ -63,7 +63,7 @@ To adopt the `LocalTieredStorage`, the test library needs to be built locally: ```bash # please checkout to the specific version tag you're using before building it -# ex: `git checkout 4.3.0` +# ex: `git checkout 4.3.1` $ ./gradlew clean :storage:testJar ``` @@ -80,7 +80,7 @@ remote.log.metadata.manager.listener.name=PLAINTEXT # This is the mandatory configuration for tiered storage. # Here, we use the `LocalTieredStorage` built above. remote.log.storage.manager.class.name=org.apache.kafka.server.log.remote.storage.LocalTieredStorage -remote.log.storage.manager.class.path=/PATH/TO/kafka-storage-4.3.0-test.jar +remote.log.storage.manager.class.path=/PATH/TO/kafka-storage-4.3.1-test.jar # These 2 prefix are default values, but customizable remote.log.storage.manager.impl.prefix=rsm.config. diff --git a/content/en/43/streams/developer-guide/datatypes.md b/content/en/43/streams/developer-guide/datatypes.md index 240b39fcf8..7d9a905b8f 100644 --- a/content/en/43/streams/developer-guide/datatypes.md +++ b/content/en/43/streams/developer-guide/datatypes.md @@ -92,7 +92,7 @@ Apache Kafka includes several built-in serde implementations for Java primitives <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> - <version>4.3.0</version> + <version>4.3.1</version> </dependency> This artifact provides the following serde implementations under the package [org.apache.kafka.common.serialization](https://github.com/apache/kafka/blob/4.3/clients/src/main/java/org/apache/kafka/common/serialization), which you can leverage when e.g., defining default serializers in your Streams configuration. @@ -220,7 +220,7 @@ Apache Kafka Streams includes serde implementations for windowed types in its `k <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> - <version>4.3.0</version> + <version>4.3.1</version> </dependency> This artifact provides the following windowed serde implementations under the package [org.apache.kafka.streams.kstream](https://github.com/apache/kafka/blob/4.3/streams/src/main/java/org/apache/kafka/streams/kstream): diff --git a/content/en/43/streams/developer-guide/dsl-api.md b/content/en/43/streams/developer-guide/dsl-api.md index 6a4d2e1671..57259556dc 100644 --- a/content/en/43/streams/developer-guide/dsl-api.md +++ b/content/en/43/streams/developer-guide/dsl-api.md @@ -5807,7 +5807,7 @@ The library is cross-built with Scala 2.12 and 2.13. To reference the library co <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams-scala_2.13</artifactId> - <version>4.3.0</version> + <version>4.3.1</version> </dependency> To use the library compiled against Scala 2.12 replace the `artifactId` with `kafka-streams-scala_2.12`. @@ -5815,7 +5815,7 @@ To use the library compiled against Scala 2.12 replace the `artifactId` with `ka When using SBT then you can reference the correct library using the following: - libraryDependencies += "org.apache.kafka" %% "kafka-streams-scala" % "4.3.0" + libraryDependencies += "org.apache.kafka" %% "kafka-streams-scala" % "4.3.1" ## Sample Usage diff --git a/content/en/43/streams/developer-guide/testing.md b/content/en/43/streams/developer-guide/testing.md index 78172d9bc2..91902af97d 100644 --- a/content/en/43/streams/developer-guide/testing.md +++ b/content/en/43/streams/developer-guide/testing.md @@ -39,7 +39,7 @@ To test a Kafka Streams application, Kafka provides a test-utils artifact that c <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams-test-utils</artifactId> - <version>4.3.0</version> + <version>4.3.1</version> <scope>test</scope> </dependency> diff --git a/content/en/43/streams/developer-guide/write-streams-app.md b/content/en/43/streams/developer-guide/write-streams-app.md index 0ee70d8bc2..dc4784ab11 100644 --- a/content/en/43/streams/developer-guide/write-streams-app.md +++ b/content/en/43/streams/developer-guide/write-streams-app.md @@ -73,7 +73,7 @@ Description </td> <td> -`4.3.0` +`4.3.1` </td> <td> @@ -90,7 +90,7 @@ Description </td> <td> -`4.3.0` +`4.3.1` </td> <td> @@ -107,7 +107,7 @@ Description </td> <td> -`4.3.0` +`4.3.1` </td> <td> @@ -124,17 +124,17 @@ Example `pom.xml` snippet when using Maven: <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams</artifactId> - <version>4.3.0</version> + <version>4.3.1</version> </dependency> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> - <version>4.3.0</version> + <version>4.3.1</version> </dependency> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-streams-scala_2.13</artifactId> - <version>4.3.0</version> + <version>4.3.1</version> </dependency> # Using Kafka Streams within your application code diff --git a/content/en/43/streams/quickstart.md b/content/en/43/streams/quickstart.md index 9651c198c8..e31bbf4fbb 100644 --- a/content/en/43/streams/quickstart.md +++ b/content/en/43/streams/quickstart.md @@ -66,11 +66,11 @@ As the first step, we will start Kafka (unless you already have it started) and ### Step 1: Download the code -[Download](https://www.apache.org/dyn/closer.cgi?path=/kafka/4.3.0/kafka_2.13-4.3.0.tgz "Kafka downloads") the 4.3.0 release and un-tar it. Note that there are multiple downloadable Scala versions and we choose to use the recommended version (2.13) here: +[Download](https://www.apache.org/dyn/closer.cgi?path=/kafka/4.3.1/kafka_2.13-4.3.1.tgz "Kafka downloads") the 4.3.1 release and un-tar it. Note that there are multiple downloadable Scala versions and we choose to use the recommended version (2.13) here: - $ tar -xzf kafka_2.13-4.3.0.tgz - $ cd kafka_2.13-4.3.0 + $ tar -xzf kafka_2.13-4.3.1.tgz + $ cd kafka_2.13-4.3.1 ### Step 2: Start the Kafka server diff --git a/content/en/43/streams/tutorial.md b/content/en/43/streams/tutorial.md index 7484d483b0..dc0016cda8 100644 --- a/content/en/43/streams/tutorial.md +++ b/content/en/43/streams/tutorial.md @@ -38,7 +38,7 @@ We are going to use a Kafka Streams Maven Archetype for creating a Streams proje $ mvn archetype:generate \ -DarchetypeGroupId=org.apache.kafka \ -DarchetypeArtifactId=streams-quickstart-java \ - -DarchetypeVersion=4.3.0 \ + -DarchetypeVersion=4.3.1 \ -DgroupId=streams.examples \ -DartifactId=streams-quickstart \ -Dversion=0.1 \ diff --git a/content/en/blog/releases/ak-4.3.1.md b/content/en/blog/releases/ak-4.3.1.md new file mode 100644 index 0000000000..a3d103ae24 --- /dev/null +++ b/content/en/blog/releases/ak-4.3.1.md @@ -0,0 +1,31 @@ +--- +date: 2026-06-25 +title: Apache Kafka 4.3.1 Release Announcement +linkTitle: AK 4.3.1 +author: Bill Bejeck +--- + +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> + +We are proud to announce the release of Apache Kafka 4.3.1. This is a bugfix release that includes several critical fixes, most notably a fix for a Kafka Streams RocksDB native memory leak. For a full list of changes, be sure to check the [release notes](https://downloads.apache.org/kafka/4.3.1/RELEASE_NOTES.html). + +See the [Upgrading to 4.3.1](https://kafka.apache.org/43/getting-started/upgrade/#upgrading-to-431) section in the documentation for the list of notable changes and detailed upgrade steps. + +## Summary + +This was a community effort, so thank you to everyone who contributed to this release, including all our users and our 23 contributors: Andrew Schofield, Apoorv Mittal, Bill Bejeck, Chia-Ping Tsai, ChickenchickenLove, David Jacot, Dongnuo Lyu, Evan Zhou, gabriellafu, Ken Huang, LeiXiaoGao, Lianet Magrans, Lucas Brutschy, MarkLee131, Matthias J. Sax, Mickael Maison, Murali Basani, Nick Telford, nileshkumar3, PoAn Yang, Sean Quah, Shekhar Prasad Rajak, Uladzislau Blok \ No newline at end of file diff --git a/content/en/community/downloads.md b/content/en/community/downloads.md index 331570eda9..cb49440423 100644 --- a/content/en/community/downloads.md +++ b/content/en/community/downloads.md @@ -37,7 +37,7 @@ The project goal is to have 3 releases a year, which means a release every 4 mon * Source download: [kafka-4.3.1-src.tgz](https://www.apache.org/dyn/closer.lua/kafka/4.3.1/kafka-4.3.1-src.tgz?action=download) ([asc](https://downloads.apache.org/kafka/4.3.1/kafka-4.3.1-src.tgz.asc), [sha512](https://downloads.apache.org/kafka/4.3.1/kafka-4.3.1-src.tgz.sha512)) * Binary download: [kafka_2.13-4.3.1.tgz](https://www.apache.org/dyn/closer.lua/kafka/4.3.1/kafka_2.13-4.3.1.tgz?action=download) ([asc](https://downloads.apache.org/kafka/4.3.1/kafka_2.13-4.3.1.tgz.asc), [sha512](https://downloads.apache.org/kafka/4.3.1/kafka_2.13-4.3.1.tgz.sha512)) -Kafka 4.3.1 fixes around 15 issues since the 4.3.0 release, most notably a critical Kafka Streams RocksDB native memory leak (KAFKA-20616). For more information, please read the detailed [Upgrade Notes](https://kafka.apache.org/43/getting-started/upgrade/#upgrading-to-431) and the [Release Notes](https://www.apache.org/dyn/closer.lua/kafka/4.3.1/RELEASE_NOTES.html?action=download). +Kafka 4.3.1 fixes around 15 issues since the 4.3.0 release, most notably a critical Kafka Streams RocksDB native memory leak (KAFKA-20616). For more information, please read our [blog post](https://kafka.apache.org/blog/2026/06/25/apache-kafka-4.3.1-release-announcement/), the detailed [Upgrade Notes](https://kafka.apache.org/43/getting-started/upgrade/#upgrading-to-431) and the [Release Notes](https://www.apache.org/dyn/closer.lua/kafka/4.3.1/RELEASE_NOTES.html?action=download). ### 4.2.1
