Versions Compared

Old Version 14

changes.mady.by.user Bill Bejeck

Saved on

compared with

New Version Current

changes.mady.by.user Bill Bejeck

Saved on

Key

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

...

  • 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.

KIPJIRAComponentKIP-671: Introduce Kafka Streams Specific Uncaught Exception Handler
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9331
,  JiraserverASF JIRAserverId5aa69414-a9e9-3523-82ec-879b028fb15bkeyKAFKA-6943,Kafka StreamsKIP-662: Throw Exception when Source Topics of a Streams App are Deleted

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

Kafka StreamsKIP-654: Aborted transaction with non-flushed data should throw a non-fatal exception

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

Kafka ClientsKIP-651 - Support PEM format for SSL certificates and private key
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-10338


CoreKIP-648: Renaming getter method for Interactive Queries

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

Kafka StreamsKIP-632: Add DirectoryConfigProvider

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


KIP-626: Rename StreamsConfig config variable name

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

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

jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6435

Kafka StreamsKIP-620 Deprecate ConsumerConfig#addDeserializerToConfig and ProducerConfig#addSerializerToConfig

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

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

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

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

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

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

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

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

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-10023
, current 
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-10024

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

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

Kafka StreamsKIP-601: Configurable socket connection timeout in NetworkClient

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

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

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

CoreKIP-597: MirrorMaker2 internal topics Formatters

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


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

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

Core

9755


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

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

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

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

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

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

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

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

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

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

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

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

Kafka StreamsMirror Maker 2.0KIP-508: Make Suppression State Queriable431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter

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

Kafka StreamsTools


Postponed to subsequent release


KIPJIRAComponent
KIP-
497: Add inter-broker API to alter ISR
671: Introduce Kafka Streams Specific Uncaught Exception Handler

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

8836

6943
,

Kafka Streams
Core
KIP-
466: Add support for List<T> serialization and deserialization
653: Upgrade log4j to log4j2

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

8326

9366


KIP-
450: Sliding Window Aggregations in the DSL
623: Add "internal-topics" option to streams application reset tool

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

5636

6435

Kafka Streams
KIP
-431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter
-608 - Expose Kafka Metrics in Authorizer

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

6733

9958

Kafka Tools
Core
KIP-
418: A method-chaining way to branch KStream
590: Redirect Zookeeper Mutation Protocols to The Controller

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

Core
KIP-589 Add API to update Replica state in Controller

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

5488

9837

Kafka Streams
Core
KIP-
373
588: Allow
users to create delegation tokens for other users
producers to recover gracefully from transaction timeouts

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

6945

9803

Kafka Clients
KIP-
359: Verify leader epoch in produce requests
580: Exponential Backoff for Kafka Clients

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

7383

9800

Core
Kafka Clients
KIP-
280: Enhanced log compaction
508: Make Suppression State Queriable

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

7061

8403

Core
Kafka Streams
KIP-
216: IQ should throw different exceptions for different errors
466: Add support for List<T> serialization and deserialization

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


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

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

5876

5488

Kafka Streams
KIP-
81: Bound Fetch memory usage in the consumer
373: Allow users to create delegation tokens for other users

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

4133Kafka Clients

Postponed to subsequent release

6945


KIP-359: Verify leader epoch in produce requests

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

Core
KIP-280: Enhanced log compaction
KIPJIRAComponent
KIP-653: Upgrade log4j to log4j2

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

Core
KIP-608 - Expose Kafka Metrics in Authorizer216: IQ should throw different exceptions for different errors

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

CoreKafka Streams
KIP-590: Redirect Zookeeper Mutation Protocols to The Controller81: Bound Fetch memory usage in the consumer

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

CoreKafka Clients