Versions Compared

Old Version 21

changes.mady.by.user Matthias Sax

Saved on

compared with

New Version Current

changes.mady.by.user Mickael Maison

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Note: The planned content is not binding - final content will be based the features committed by branch-cutting date. See Kafka Improvement Proposals for the full list of KIPs.

KIPJIRAComponentStatus
KIP-405: Kafka Tiered Storage399: Extend ProductionExceptionHandler to cover serialization exceptions

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-77397499

StreamscoreDone
KIP-581: Value of optional null field which has default value

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8713

connectDone
KIP-641 An new java interface to replace 'kafka.common.MessageReader'

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-10244

tool/clientDone
KIP-710: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-10586

connectDone
KIP--847: Add ProducerIdCount metrics

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-13999

coreDone
KIP-875: First-class offsets support in Kafka Connect726: Make the "cooperative-sticky, range" as the default assignor

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-124734107

connect

Partially Done

Includes internal changes + list offsets API

clients

KIP-881: Rack-aware Partition Assignment for Kafka Consumers

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-14352

client

Done (updated assignors, 3.4 only had the new protocol)

KIP-884: Add config to configure KafkaClientSupplier in Kafka Streams770: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-1315214395

StreamsDone
KIP-797: Accept duplicate listener on port for IPv4/IPv6887: Add ConfigProvider to make use of environment variables

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-1329914376

coreclientsPR availableDone
KIP-813889: Shareable Versioned State Stores

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-1089214491

StreamsPR availableDone
KIP-821: Connect Transforms support for nested structures893: The Kafka protocol should support nullable structs

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-1365614425

coreconnectDone
KIP-847: Add ProducerIdCount metrics894: Use incrementalAlterConfig for syncing topic configurations 

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-1399914420

coreconnectDone
KIP-863: Reduce Fetcher#parseRecord() memory copy900: KRaft kafka-storage.sh API additions to support SCRAM for Kafka Brokers

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-1471514765

clientscorePR availableDone
KIP-866 ZooKeeper to KRaft Migration903: Replicas with stale broker epoch should not be allowed to join the ISR

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-1430414139

coreDone

KIP-

875

904:

First-class offsets support in Kafka Connect

Kafka Streams - Guarantee subtractor is called before adder if key has not changed

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-410712446

connectStreamsDone (system test missing)PR1, PR2
KIP-884907: Add config to configure KafkaClientSupplier in Kafka StreamsBoolean Serde to public interface

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-1439514722

StreamsDone
KIP-887911: Add ConfigProvider to make use of environment variablessource tag to Mirror source metric

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-1437614740

clientsconnectPR availableDone
KIP-889914: DSL Processor Semantics for Versioned State Stores

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-1449114834

StreamsDone

KIP-

893: The Kafka protocol should support nullable structs

915: Txn and Group Coordinator Downgrade Foundation

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-1442514869

coreDone


Postponed to subsequent release

KIPJIRA
KIP-
894: Use incrementalAlterConfig for syncing topic configurations 
405: Kafka Tiered Storage

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-

14420connectPR availableKIP-900: KRaft kafka-storage.sh API additions to support SCRAM for Kafka Brokers

7739

KIP-726: Make the "cooperative-sticky, range" as the default assignor

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-12473

KIP-770: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-13152

KIP-797: Accept duplicate listener on port for IPv4/IPv6

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA

-14765coreDone

-13299

KIP-813: Shareable State Stores

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-10892

KIP-
907: Add Boolean Serde to public interface
821: Connect Transforms support for nested structures

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-

14722StreamsDone (only docs missing)KIP-911: Add source tag to Mirror source metric

13656

KIP-863: Reduce Fetcher#parseRecord() memory copy

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-14715

KIP-866 ZooKeeper to KRaft Migration

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-

14740connect

14304

Done
KIP-
915: Txn and Group Coordinator Downgrade Foundation
898: Modernize Connect plugin discovery

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-

14869core

...

14627