THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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.
KIP | JIRA | Component | ||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
KIP- | 783: Add TaskId field to StreamsException775: Custom partitioners in foreign key joins |
| 13381
| Streams | ||||||||||||||||||||
KIP-775: Custom partitioners in foreign key joins783: Add TaskId field to StreamsException |
| Streams | ||||||||||||||||||||||
KIP-773: Differentiate consistently metric latency measured in millis and nanos |
| Clients | ||||||||||||||||||||||
KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC |
| Core/Clients | ||||||||||||||||||||||
KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore |
| Streams | ||||||||||||||||||||||
KIP-763: Range queries with open endpoints |
| Streams | ||||||||||||||||||||||
KIP-761: Add Total Blocked Time Metric to Streams |
| Streams | ||||||||||||||||||||||
KIP-748: Add Broker Count Metrics |
| Core | ||||||||||||||||||||||
KIP-726: Make the "cooperative-sticky, range" as the default assignor690: Add additional configuration to control MirrorMaker 2 internal topics naming convention |
| ClientsMirrorMaker | ||||||||||||||||||||||
KIP-708: Rack awareness for Kafka 633: Deprecate 24-hour Default Grace Period for Windowed Operations in Streams | KIP-691: Enhance Transactional Producer Exception Handling
| Streams |
| Streams |
Postponed to subsequent release
KIP | JIRA | Component |
---|---|---|
KIP- |
726: Make the "cooperative-sticky, range" as the default assignor |
|
|
Clients |
KIP- |
709: Extend OffsetFetch requests to accept multiple group ids. |
|
| Clients |
KIP- |
708: Rack aware StandbyTask assignment for Kafka Streams |
|
| Streams | ||
KIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams |
|
| Streams | ||
KIP- |
691: Enhance Transactional Producer Exception Handling |
|
|
Clients |
KIP- |
627: Expose Trogdor-specific JMX Metrics for Tasks and Agents |
|
Postponed to subsequent release
| Trogdor | ||||||||||||||||||||
KIP-618: Exactly-Once Support for Source Connectors | |||||||||||||||||||||
KIP | JIRA | Component | |||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
KIP-709: Extend OffsetFetch requests to accept multiple group ids. |
| Clients | KIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams | /
| StreamsConnect | ||||||||||||||||
KIP-627: Expose Trogdor-specific JMX Metrics for Tasks and Agents653: Upgrade log4j to log4j2 |
| Clients, Connect, Core, StreamsTrogdor | |||||||||||||||||||
KIP-618: Exactly-Once Support for Source Connectors405: Kafka Tiered Storage |
| Core | |||||||||||||||||||
KIP-390: Support Compression Level |
| ConnectCore, Clients |