Page History

...

KIP Freeze: Sep 30, 2020 (a KIP must be accepted by this date in order to be considered for this release)
Feature Freeze: Oct 7, 2020 (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: Oct 21, 2020Release: estimated
Nov 6Released Dec 21, 2020

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 target release date is fixed at ~2w after code freeze, 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-671: Introduce Kafka Streams Specific Uncaught Exception Handler

Jira

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

,

Jira

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

,KIP-662: Throw Exception when Source Topics of a Streams App are Deleted

Jira

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

Kafka StreamsKIP-653: Upgrade log4j to log4j2654: Aborted transaction with non-flushed data should throw a non-fatal exception

Jira

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

Kafka ClientsKIP-651 - Support PEM format for SSL certificates and private key

Jira

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

CoreKIP-648: Renaming getter method for Interactive Queries

Jira

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

Kafka StreamsKIP-632: Add DirectoryConfigProvider

Jira

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

,

Jira

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

KIP-626: Rename StreamsConfig config variable name

Jira

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

Kafka StreamsKIP-623: Add "internal-topics" option to streams application reset tool JiraserverASF JIRAserverId5aa69414-a9e9-3523-82ec-879b028fb15bkeyKAFKA-6435Kafka StreamsKIP-620 Deprecate ConsumerConfig#addDeserializerToConfig and ProducerConfig#addSerializerToConfig

Jira

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

Kafka ClientsKIP-617: Allow Kafka Streams State Stores to be iterated backwards

Jira

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

Kafka StreamsKIP-616: Rename implicit Serdes instances in kafka-streams-scala

Jira

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

Kafka StreamsKIP-613: Add end-to-end latency metrics to Streams

Jira

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

Kafka StreamsKIP-612: Ability to Limit Connection Creation Rate on Brokersold

Jira

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

CoreKIP-607: Add Metrics to Kafka Streams to Report Properties of RocksDB

Jira

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

, current

9924

Kafka StreamsKIP-601: Configurable socket connection timeout in NetworkClient

Jira

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

CoreKIP-608 - Expose Kafka Metrics in Authorizer599: Throttle Create Topic, Create Partition and Delete Topic Operations

Jira

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

CoreKIP-607: Add Metrics to Kafka Streams to Report Properties of RocksDB597: MirrorMaker2 internal topics Formatters

Jira

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

KIP-584: Versioning scheme for features

Jira

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

Kafka Streams

KIP-601: Configurable socket connection timeout in NetworkClient572: Improve timeouts and retries in Kafka Streams

Jira

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

CoreKafka StreamsKIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations554: Add Broker-side SCRAM Config API

Jira

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

CoreKIP-597: MirrorMaker2 internal topics Formatters545: support automated consumer offset sync across clusters in MM 2.0

Jira

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

Mirror Maker 2.0KIP-589 497: Add inter-broker API to update Replica state in Controlleralter ISR

Jira

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

CoreKIP-588: Allow producers to recover gracefully from transaction timeouts478 - Strongly typed Processor API

Jira

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

Kafka ClientsStreamsKIP-584: Versioning scheme for features450: Sliding Window Aggregations in the DSL

Jira

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

Kafka StreamsKIP-580: Exponential Backoff for Kafka Clients431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter

Jira

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

Kafka ClientsTools

Postponed to subsequent release

KIP	JIRA	Component
KIP-

572: Improve timeouts and retries in

671: Introduce Kafka Streams Specific Uncaught Exception Handler

Jira

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

9274

9331

,

Jira

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

,

Kafka Streams

KIP

-554: Add Broker-side SCRAM Config API

-653: Upgrade log4j to log4j2

Jira

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

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

Jira

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

10259

6435

Core

Kafka Streams

KIP-

545: support automated consumer offset sync across clusters in MM 2.0

608 - Expose Kafka Metrics in Authorizer

Jira

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

9076Mirror Maker 2.0

9958

Core

KIP-

508: Make Suppression State Queriable

590: Redirect Zookeeper Mutation Protocols to The Controller

Jira

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

8403

9705

Kafka Streams

Core

KIP-

497:

589 Add

inter-broker

API to

alter ISR

update Replica state in Controller

Jira

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

8836

9837

Core

KIP-

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

588: Allow producers to recover gracefully from transaction timeouts

Jira

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

Kafka Clients

KIP-580: Exponential Backoff for Kafka Clients

Jira

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

8326

9800

Kafka Clients

KIP-

450: Sliding Window Aggregations in the DSL

508: Make Suppression State Queriable

Jira

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

5636

8403

Kafka Streams

KIP-

431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter

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

Jira

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

6733

8326

Kafka Tools

KIP-418: A method-chaining way to branch KStream

Jira

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

Kafka Streams

KIP-373: Allow users to create delegation tokens for other users

Jira

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

KIP-359: Verify leader epoch in produce requests

Jira

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

Core

KIP-280: Enhanced log compaction

Jira

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

Core

KIP-216: IQ should throw different exceptions for different errors

Jira

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

Kafka Streams

KIP-81: Bound Fetch memory usage in the consumer

Jira

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

Kafka Clients

Postponed to subsequent release

KIP

JIRA

Component

KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

Jira

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

Core

Space shortcuts

Child pages

Versions Compared

Old Version 11

New Version Current

Key

Postponed to subsequent release

Postponed to subsequent release