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.

5aa69414-a9e9-3523-82ec-879b028fb15b,

KIP	JIRA	Component
KIP-671: Introduce Kafka Streams Specific Uncaught Exception Handler
Jira
server	ASF JIRA
serverId
key	KAFKA-9331

Jira

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

,Kafka StreamsKIP-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-654: Aborted transaction with non-flushed data should throw a non-fatal exception

Jira

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

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

Jira

serverId

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

Kafka 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 Brokers

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-9924

Kafka StreamsKIP-601: Configurable socket connection timeout in NetworkClient

Jira

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

CoreKIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

Jira

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

CoreKIP-597: MirrorMaker2 internal topics Formatters

Jira

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

KIP-589 Add API to update Replica state in Controller584: Versioning scheme for features

Jira

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

Core

9755

KIP-588: Allow producers to recover gracefully from transaction timeouts572: Improve timeouts and retries in Kafka Streams

Jira

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

Kafka ClientsStreamsKIP-584: Versioning scheme for features554: Add Broker-side SCRAM Config API

Jira

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

CoreKIP-580: Exponential Backoff for Kafka Clients545: support automated consumer offset sync across clusters in MM 2.0

Jira

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

Mirror Maker 2.0Kafka ClientsKIP-572: Improve timeouts and retries in Kafka Streams497: Add inter-broker API to alter ISR

Jira

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

Kafka StreamsCoreKIP-554: Add Broker-side SCRAM Config 478 - Strongly typed Processor API

Jira

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

CoreKafka StreamsKIP-545: support automated consumer offset sync across clusters in MM 2.0450: Sliding Window Aggregations in the DSL

Jira

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

Kafka StreamsMirror Maker 2.0KIP-497: Add inter-broker API to alter ISR431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter

Jira

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

CoreKIP-478 - Strongly typed Processor API

6733

Kafka Tools

Postponed to subsequent release

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-

8410

6943

,

Kafka Streams

KIP-

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

653: Upgrade log4j to log4j2

Jira

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

8326

9366

KIP-

450: Sliding Window Aggregations in the DSL

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

Jira

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

5636

6435

Kafka Streams

KIP

-431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter

-608 - Expose Kafka Metrics in Authorizer

Jira

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

6733

9958

Kafka Tools

Core

KIP-

418: A method-chaining way to branch KStream

590: Redirect Zookeeper Mutation Protocols to The Controller

Jira

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

5488

9705

Kafka Streams

Core

KIP-

373: Allow users to create delegation tokens for other users

589 Add API to update Replica state in Controller

Jira

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

6945

9837

Core

KIP-

359: Verify leader epoch in produce requests

588: Allow producers to recover gracefully from transaction timeouts

Jira

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

7383

9803

Core

Kafka Clients

KIP-

280: Enhanced log compaction

580: Exponential Backoff for Kafka Clients

Jira

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

7061

9800

Core

Kafka Clients

KIP-

216: IQ should throw different exceptions for different errors

508: Make Suppression State Queriable

Jira

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

5876

8403

Kafka Streams

KIP-

81: Bound Fetch memory usage in the consumer

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

Jira

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

4133Kafka Clients

Postponed to subsequent release

8326

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

KIP

JIRA

Component

KIP-653: Upgrade log4j to log4j2

Jira

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

KIP-608 - Expose Kafka Metrics in Authorizer359: Verify leader epoch in produce requests

Jira

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

Core

KIP-590: Redirect Zookeeper Mutation Protocols to The Controller280: Enhanced log compaction

Jira

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

Core

KIP-508: Make Suppression State Queriable216: IQ should throw different exceptions for different errors

Jira

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

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

Space shortcuts

Child pages

Versions Compared

Old Version 18

New Version Current

Key

Postponed to subsequent release

Postponed to subsequent release