Versions Compared

Key

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

...

  • KIP Freeze:  (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):  (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):  
  • At least two weeks of stabilization will follow Code Freeze.

...

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.

KIPJIRAComponent
KIP-775: Custom partitioners in foreign key joins

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

Streams
KIP-783: Add TaskId field to StreamsException

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

Streams
KIP-773: Differentiate consistently metric latency measured in millis and nanos

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

Clients
KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC

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

Core/Clients
KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore

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

Streams
KIP-763: Range queries with open endpoints

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

Streams
KIP-761: Add Total Blocked Time Metric to Streams

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

Streams
KIP-748: Add Broker Count Metrics

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

Core
KIP-690: Add additional configuration to control MirrorMaker 2 internal topics naming convention

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

MirrorMaker
KIP-633: Deprecate 24-hour Default Grace Period for Windowed Operations in Streams

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

Streams


Postponed to subsequent release

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

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

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

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

Clients
KIP-708: Rack
awareness
aware StandbyTask assignment for Kafka Streams

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

Streams
KIP-
691: Enhance Transactional Producer Exception Handling
698: Add Explicit User Initialization of Broker-side State to Kafka Streams

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

10733

10357

Clients
Streams
KIP-
653: Upgrade log4j to log4j2
691: Enhance Transactional Producer Exception Handling

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

9366

10733

All
Clients
KIP-627: Expose Trogdor-specific JMX Metrics for Tasks and Agents

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

Trogdor
KIP-618: Exactly-Once Support for Source Connectors

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

Connect
KIP-
405: Kafka Tiered Storage
653: Upgrade log4j to log4j2

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

7739

9366

Clients, Connect, Core, Streams
KIP-
390: Support Compression Level
405: Kafka Tiered Storage

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

7632

7739

Core

...

KIPJIRAComponentKIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams-390: Support Compression Level

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

StreamsCore, Clients