Driss

Kfaka test

BLOG

APACHE KAFKA 3.5.2 RELEASE ANNOUNCEMENT

11 December 2023 - Luke Chen (@showuon1)

We are proud to announce the release of Apache Kafka 3.5.2. This is a bugfix release. It contains many bug fixes including upgrades the Snappy and Rocksdb dependencies. For a full list of changes, be sure to check the release notes.

See the Upgrading to 3.5.2 from any version 0.8.x through 3.4.x 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:
A. Sophie Blee-Goldman, Anna Sophie Blee-Goldman, atu-sharm, bachmanity1, Bill Bejeck, Calvin Liu, Chase Thomas, Chris Egerton, Christo Lolov, Colin P. McCabe, Colin Patrick McCabe, David Arthur, David Jacot, Divij Vaidya, Farooq Qaiser, Federico Valeri, flashmouse, Florin Akermann, Greg Harris, Guozhang Wang, Hao Li, hudeqi, Ismael Juma, Jason Gustafson, José Armando García Sancio, Josep Prat, Levani Kokhreidze, lixy, Lucas Brutschy, Luke Chen, Manikumar Reddy, Matthias J. Sax, Mickael Maison, Nick Telford, Okada Haruki, Omnia G.H Ibrahim, Philip Nee, Qichao Chu (@ex172000), Mickael Maison, Rajini Sivaram, Ritika Reddy, Robert Wagner, Rohan, Ron Dagostino, Sagar Rao, Said Boudjelda, sciclon2, Viktor Somogyi-Vass, Vincent Jiang, Xiaobing Fang, Yash Mayya

APACHE KAFKA 3.6.1 RELEASE ANNOUNCEMENT

7 December 2023 - Mickael Maison (@MickaelMaison)

We are proud to announce the release of Apache Kafka 3.6.1. This is a bugfix release. It contains 30 fixes including upgrades to the ZooKeeper and Netty dependencies. For a full list of changes, be sure to check the release notes.

See the Upgrading to 3.6.1 from any version 0.8.x through 3.5.x 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:
Anna Sophie Blee-Goldman, Arpit Goyal, atu-sharm, Bill Bejeck, Chris Egerton, Colin P. McCabe, David Arthur, David Jacot, Divij Vaidya, Federico Valeri, Greg Harris, Guozhang Wang, Hao Li, hudeqi, iit2009060, Ismael Juma, Jorge Esteban Quilcate Otoya, Josep Prat, Jotaniya Jeel, Justine Olshan, Kamal Chandraprakash, kumarpritam863, Levani Kokhreidze, Lucas Brutschy, Luke Chen, Manikumar Reddy, Matthias J. Sax, Mayank Shekhar Narula, Mickael Maison, Nick Telford, Philip Nee, Qichao Chu, Rajini Sivaram, Robert Wagner, Sagar Rao, Satish Duggana, Walker Carlson, Xiaobing Fang, Yash Mayya

APACHE KAFKA 3.6.0 RELEASE ANNOUNCEMENT

10 Oct 2023 - Satish Duggana (@SatishDuggana)

We are proud to announce the release of Apache Kafka 3.6.0. This release contains many new features and improvements. This blog post will highlight some of the more prominent features. For a full list of changes, be sure to check the release notes.

See the Upgrading to 3.6.0 from any version 0.8.x through 3.5.x section in the documentation for the list of notable changes and detailed upgrade steps.

The ability to migrate Kafka clusters from a ZooKeeper metadata system to a KRaft metadata system is now ready for usage in production environments. See the ZooKeeper to KRaft migration operations documentation for details. Note that support for JBOD is still not available for KRaft clusters, therefore clusters utilizing JBOD can not be migrated. See KIP-858 for details regarding KRaft and JBOD.

Support for Delegation Tokens in KRaft (KAFKA-15219) was completed in 3.6, further reducing the gap of features between ZooKeeper-based Kafka clusters and KRaft. Migration of delegation tokens from ZooKeeper to KRaft is also included in 3.6.

Tiered Storage is an early access feature. It is currently only suitable for testing in non production environments. See the Early Access Release Notes for more details.

Note: ZooKeeper is marked as deprecated since 3.5.0 release. ZooKeeper is planned to be removed in Apache Kafka 4.0. For more information, please see the documentation for ZooKeeper Deprecation

 

Kafka Broker, Controller, Producer, Consumer and Admin Client

• KIP-405: Kafka Tiered Storage (Early Access):
  Introduces Tiered Storage to Kafka. Note that this is an early access feature only advised for use in non-production environments (see the early access notes for more information). This feature provides a separation of computation and storage in the broker for pluggable storage tiering natively in Kafka Tiered Storage brings a seamless extension of storage to remote objects with minimal operational changes.
• KIP-890: Transactions Server Side Defense (Part 1):
  Hanging transactions can negatively impact your read committed consumers and prevent compacted logs from being compacted. KIP-890 helps address hanging transactions by verifying partition additions. Part 2 of KIP-890 will optimize verification, which currently adds an extra hop.
  In 3.6.0, transaction verification will prevent hanging transactions on data partitions. In the next release, transactional offset commits will also be covered.
• KIP-797: Accept duplicate listener on port for IPv4/IPv6:
  Until now, Kafka has not supported duplicate listeners on the same port. This works when using only a single IP stack, but presents an issue if you are working with both IPv4 and IPv6. With KIP-797, brokers can be configured with listeners that have the same port on different IP stacks. This update does not affect advertised listeners, which already have this feature.
• KIP-863: Reduce CompletedFetch#parseRecord() memory copy:
  Reduces memory allocation and improves memory performance during record deserialization by using a ByteBuffer instead of byte[] for deserialization, which improves efficiency. Updated public interfaces include the Deserializer class, ByteBufferDeserializer class, and StringDeserializer class.
• KIP-868: Metadata Transactions:
  Improves the overall durability of the KRaft layer by adding metadata transactions that consist of:
  • BeginTransaction
  • Number of records
  • EndTransaction or AbortTransaction
• KIP-902: Upgrade Zookeeper to 3.8.2:
  This upgrades the ZooKeeper version that is bundled with Kafka to version 3.8.2. The new version includes several updates and security improvements.
• KIP-917: Additional custom metadata for remote log segment:
  It introduces having an optional custom metadata as part of remote log segment metadata. RemoteStorageManager returns the optional custom metadata when copyLogSegmentData() is invoked. It will be passed along with remote log segment metadata.
• KIP-937: Improve Message Timestamp Validation:
  It improves data integrity and prevents potential pitfalls caused by inaccurate timestamp handling by adding more validation logic for message timestamps. While past timestamps are a normal occurrence in Kafka, future timestamps might represent an incorrectly formatted integer. KIP-937 rejects messages with future timestamps and provides a descriptive exemption.
• KIP-938: Add more metrics for measuring KRaft performance:
  Adds new controller, loader, and snapshot emitter KRaft performance metrics.

Kafka Streams

• KIP-923: Add A Grace Period to Stream Table Join:
  Adds a grace period to stream-table joins to improve table-side out-of-order data handling. The joined object has a new method called "withGracePeriod" that will cause the table side lookup to only happen after the grace period has passed.
• KIP-941: Range queries to accept null lower and upper bounds:
  Previously, RangeQuery did not support null to specify “no upper/lower bound”. KIP-941 allows users to pass null into withRange(...) for lower/upper bounds to specify a full or half-open range:
  • `withRange(null, null)` == `withNoBounds()`
  • `withRange(lower, null)` == `withLowerBound(lower)`
  • `withRange(null, upper)` == `withUpperBound(upper)`

Kafka Connect

• KIP-793: Allow sink connectors to be used with topic-mutating SMTs:
  Adds support for topic-mutating SMTs for async sink connectors. This is to address an incompatibility between sink connectors overriding the SinkTask::preCommit method and SMTs that mutate the topic field of a SinkRecord .
• KIP-875: First-class offsets support in Kafka Connect:
  Provides first-class admin support for offsets in Kafka Connect. KIP-875 Part 1 added endpoints to get offsets and a new STOPPED state for connectors. The alter offsets and reset offsets endpoints have now been added.

Action	Description
GET /connectors/{connector}/offsets	Retrieve the offsets for a connector; the connector must exist
PATCH /connectors/{connector}/offsets	Alter the offsets for a connector; the connector must exist, and must be in the STOPPED state
DELETE /connectors/{connector}/offsets	Reset the offsets for a connector; the connector must exist, and must be in the STOPPED state
PUT /connectors/{connector}/pause	Pause the connector; the connector must exist

• KIP-898: Modernize Connect plugin discovery:
  With KIP-898, Connect workers can now read from ServiceLoader manifests and module info directly during startup for more efficient plugin class discovery. Note that this update allows connector developers to add service declarations to their plugins.

Summary

Ready to get started with Apache Kafka 3.6.0? Check out all the details in the release notes and download Apache Kafka 3.6.0.