This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a commit to branch markdown
in repository https://gitbox.apache.org/repos/asf/kafka-site.git
The following commit(s) were added to refs/heads/markdown by this push:
new 4b8ee1ce95 Add blog post and fix some trailing 4.3.0 references (#890)
4b8ee1ce95 is described below
commit 4b8ee1ce9518e6a082e198f15cb9faeefb8c4ae3
Author: Bill Bejeck <[email protected]>
AuthorDate: Thu Jun 25 20:40:40 2026 -0400
Add blog post and fix some trailing 4.3.0 references (#890)
---
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
