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

Streams
KIPJIRAComponentKIP-775: Custom partitioners in foreign key joins

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

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-698: Add Explicit User Initialization of Broker-side State to Kafka Streams

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

Streams
KIP-691: Enhance Transactional Producer Exception Handling

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

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-653: Upgrade log4j to log4j2

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

Clients, Connect, Core, Streams
KIP-405: Kafka Tiered Storage

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

Core
KIP-390: Support Compression Level

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

Core, Clients

...