Versions Compared

Key

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

...

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-726: Make the "cooperative-sticky, range" as the default assignor690: Add additional configuration to control MirrorMaker 2 internal topics naming convention

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

ClientsMirrorMaker
KIP-709: Extend OffsetFetch requests to accept multiple group ids.633: Deprecate 24-hour Default Grace Period for Windowed Operations in Streams

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

ClientsKIP-708: Rack awareness for Kafka Streams

/

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

Streams


Postponed to subsequent release

KIP
-691: Enhance Transactional Producer Exception Handling
JIRAComponent
KIP-726: Make the "cooperative-sticky, range" as the default assignor

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

10733

12473

Clients
KIP-
690: Add additional configuration to control MirrorMaker 2 internal topics naming convention
709: Extend OffsetFetch requests to accept multiple group ids.

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

10777

13043

MirrorMaker
Clients
KIP-
653: Upgrade log4j to log4j2
708: Rack aware StandbyTask assignment for Kafka Streams

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

9366

6718

All
Streams
KIP-
633: Deprecate 24-hour Default Grace Period for Windowed Operations in
698: Add Explicit User Initialization of Broker-side State to Kafka Streams

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

8613

10357

Streams
KIP-691: Enhance Transactional Producer Exception Handling
/

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

12909

10733

Streams
Clients
KIP-
618
627:
Exactly-Once Support for Source Connectors
Expose Trogdor-specific JMX Metrics for Tasks and Agents

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

10000 /

8528

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

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

6080KIP-405: Kafka Tiered Storage

10000

Connect

/

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

7739

6080

Core
Connect
KIP-
390: Support Compression Level
653: Upgrade log4j to log4j2

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

7632

9366

Clients, Connect, Core, Streams

Postponed to subsequent release

KIPJIRAComponentKIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams-405: Kafka Tiered Storage

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

StreamsCore
KIP-627: Expose Trogdor-specific JMX Metrics for Tasks and Agents390: Support Compression Level

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

TrogdorCore, Clients