Page History

...

KIP Freeze: 09 Jun 2021 (A KIP must be accepted by this date in order to be considered for this release. Note, any KIP that may not be implemented in a week, or that might destabilize the release, should be deferred.)
Feature Freeze (new date): 16 30 Jun 2021 (major features merged & working on stabilization, minor features have PR, release branch cut; anything not in this state will be automatically moved to the next release in JIRA)
Code Freeze (new date): 30 Jun 14 Jul 2021
At least two weeks of stabilization will follow code freezeCode Freeze.

These dates are goals and subject to change, but we expect to stay on the Time Based Release Plan unless unexpected critical issues come up. While the earliest possible release date is 2w after code freeze, release candidates (RCs) will roll out as needed until the release vote passes.

...

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.

KIP

JIRA

Component

KIP-715: Expose Committed offset in streams751: Drop support for Scala 2.12 in Kafka 4.0 (deprecate in 3.0)

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12930

Documentation

KIP-750: Drop support for Java 8 in Kafka 4.0 (deprecate in 3.0)

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12929

Documentation

KIP-746: Revise KRaft Metadata Records

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12931

Core

KIP-745: Connect API to restart connector and tasks

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-4793

Connect

KIP-744: Migrate TaskMetadata and ThreadMetadata to an interface with internal implementation

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-1234712849

Streams

KIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams743: Remove config value 0.10.0-2.4 of Streams built-in metrics version config

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12519

Streams

KIP-741: Change default serde to be null

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-9559

Streams

KIP-740: Clean up public API in TaskId and fix TaskMetadata#taskId()

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-1035712779

Streams

KIP-695: Further Improve Kafka Streams Timestamp Synchronization738: Removal of Connect's internal converter properties

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12717

Connect

KIP-735: Increase default consumer session timeout

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12874

Clients

KIP-734: Improve AdminClient.listOffsets to return timestamp and offset for the record with the largest timestamp

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12541

Clients

KIP-733: change Kafka Streams default replication factor config

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-8531

Streams

KIP-732: Deprecate eos-alpha and replace eos-beta with eos-v2

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-

10091

12574

Streams

KIP-691730: Enhance Transactional Producer Exception HandlingProducer ID generation in KRaft mode

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12620

Core, Clients

KIP-725: Streamlining configurations for WindowedSerializer and WindowedDeserializer.

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12313

Streams

KIP-724: Drop support for message formats v0 and v1

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12944

Core, Clients

KIP-722: Enable connector client overrides by default

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12483

Connect

KIP-721: Enable connector log contexts in Connect Log4j configuration

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12484

Connect

KIP-720: Deprecate MirrorMaker v1

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12436

Core

KIP-716: Allow configuring the location of the offset-syncs topic with MirrorMaker2

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12379

MirrorMaker

KIP-715: Expose Committed offset in streams

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12347

Streams

KIP-709: Extend OffsetFetch requests to accept multiple group ids.

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12234

Core, Clients

KIP-707: The future of KafkaFuture

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-6987

Clients

KIP-699: Update FindCoordinator to resolve multiple Coordinators at a time

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-1073312663

Core, Clients

KIP-695: Further Improve Kafka Streams Timestamp Synchronization

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-10091

Streams

KIP-679: Producer will enable the strongest delivery guarantee by default

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-10619

Clients

KIP-622666: Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContextInstant-based methods to ReadOnlySessionStore

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-10434

Streams

KIP-633: Drop 24 hour default of grace period in Streams

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-100628613

Streams

KIP-630: Kafka Raft Snapshot

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-10310

Core

KIP-623: Add "internal-topics" option to streams application reset tool

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-6435

Streams, Tools

KIP-622: Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-10062

Streams

KIP-466: Add support for List<T> serialization and deserialization

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-8326

Clients, Streams

Postponed to subsequent release

KIP

JIRA

Component

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

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-12473

Clients

KIP-708: Rack awareness for Kafka Streams

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-6718

Streams

KIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-10357

Streams

KIP-691: Enhance Transactional Producer Exception Handling

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-10733

Clients

KIP-653: Upgrade log4j to log4j2

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-9366

Applies to almost all the components

KIP-405: Kafka Tiered Storage

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-7739

Core

Postponed to subsequent release

...

KIP-390: Support Compression Level

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-7632

Clients

Space shortcuts

Child pages

Versions Compared

Old Version 8

New Version Current

Key

Postponed to subsequent release

Postponed to subsequent release