...
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 | Status | |||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|
KIP-405: Kafka Tiered Storage399: Extend ProductionExceptionHandler to cover serialization exceptions |
| Streams | coreDone | |||||||||
KIP-581: Value of optional null field which has default value |
| connect | Done | |||||||||
KIP-641 An new java interface to replace 'kafka.common.MessageReader' |
| tool/client | Done | |||||||||
KIP-710: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters |
| connect | Done | |||||||||
KIP-847: Add ProducerIdCount metrics |
| core | Done | |||||||||
KIP-726: Make the "cooperative-sticky, range" as the default assignor875: First-class offsets support in Kafka Connect |
| connect | Partially Done Includes internal changes + list offsets API clients | |||||||||
| client | Done (updated assignors, 3.4 only had the new protocol) | ||||||||||
KIP-884: Add config to configure KafkaClientSupplier in Kafka Streams770: Replace "buffered.records.per.partition" with "input.buffer.max.bytes" |
| Streams | Done | |||||||||
KIP-797: Accept duplicate listener on port for IPv4/IPv6887: Add ConfigProvider to make use of environment variables |
| coreclients | PR availableDone | |||||||||
KIP-813889: Shareable Versioned State Stores |
| Streams | PR availableDone | |||||||||
KIP-821: Connect Transforms support for nested structures893: The Kafka protocol should support nullable structs |
| core | connectDone | |||||||||
KIP-847: Add ProducerIdCount metrics894: Use incrementalAlterConfig for syncing topic configurations |
| coreconnect | Done | |||||||||
KIP-863: Reduce Fetcher#parseRecord() memory copy900: KRaft kafka-storage.sh API additions to support SCRAM for Kafka Brokers |
| clientscore | PR availableDone | |||||||||
KIP-866 ZooKeeper to KRaft Migration903: Replicas with stale broker epoch should not be allowed to join the ISR |
| core | Done | |||||||||
875 First-class offsets support in Kafka Connect |
| connect | Streams | Done (system test missing)PR1, PR2 | ||||||||
KIP-884907: Add config to configure KafkaClientSupplier in Kafka StreamsBoolean Serde to public interface |
| Streams | Done | |||||||||
KIP-887911: Add ConfigProvider to make use of environment variablessource tag to Mirror source metric |
| clientsconnect | Done | |||||||||
KIP-889914: DSL Processor Semantics for Versioned State Stores |
| Streams | Done | |||||||||
893: The Kafka protocol should support nullable structs |
| core | Done |
Postponed to subsequent release
KIP | JIRA |
---|---|
KIP- |
405: Kafka Tiered Storage |
|
|
KIP- |
726: Make the "cooperative-sticky, range" as the default assignor |
|
| ||
KIP- |
770: Replace "buffered.records.per.partition" with "input.buffer.max.bytes" |
|
|
KIP- |
797: Accept duplicate listener on port for IPv4/IPv6 |
|
|
KIP- |
813: Shareable State Stores |
|
|
KIP- |
821: Connect Transforms support for nested structures |
|
|
KIP- |
863: Reduce Fetcher#parseRecord() memory copy |
|
| |||||||||
KIP-866 ZooKeeper to KRaft Migration |
| ||||||||
KIP- |
898: Modernize Connect plugin discovery |
|
...
|