| KIP | JIRA | Component | Status |
|---|
| KIP-405: Kafka Tiered Storage399: Extend ProductionExceptionHandler to cover serialization exceptions | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-77397499 |
|---|
|
| Streams | coreDone |
| KIP-581: Value of optional null field which has default value | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-8713 |
|---|
|
| connect | Done |
| KIP-641 An new java interface to replace 'kafka.common.MessageReader' | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-10244 |
|---|
|
| tool/client | PR availableDone |
| KIP-710: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-10586 |
|---|
|
| connect | Done |
| KIP-726: Make the "cooperative-sticky, range" as the default assignor847: Add ProducerIdCount metrics | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1247313999 |
|---|
|
| core | clientsDone |
| KIP-770: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"875: First-class offsets support in Kafka Connect | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-131524107 |
|---|
|
| connect | Partially Done Includes internal changes + list offsets API streams |
KIP- 797: Accept duplicate listener on port for IPv4/IPv6881: Rack-aware Partition Assignment for Kafka Consumers | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1329914352 |
|---|
|
| core | client | PR available Done (updated assignors, 3.4 only had the new protocol)
|
| KIP-813: Shareable State Stores884: Add config to configure KafkaClientSupplier in Kafka Streams | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1089214395 |
|---|
|
| streamsStreams | PR availableDone |
| KIP-821: Connect Transforms support for nested structures887: Add ConfigProvider to make use of environment variables | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1365614376 |
|---|
|
| clients | connectDone |
| KIP-844889: Transactional Versioned State Stores | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1254914491 |
|---|
|
| streamsStreams | PR availableDone |
| KIP-847: Add ProducerIdCount metrics893: The Kafka protocol should support nullable structs | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1399914425 |
|---|
|
| core | Done |
| KIP-862: Self-join optimization for stream-stream joins894: Use incrementalAlterConfig for syncing topic configurations | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1420914420 |
|---|
|
| connect | streamsDone |
| KIP-863: Reduce Fetcher#parseRecord() memory copy900: KRaft kafka-storage.sh API additions to support SCRAM for Kafka Brokers | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1471514765 |
|---|
|
| clientscore | PR availableDone |
| KIP-866 ZooKeeper to KRaft Migration903: Replicas with stale broker epoch should not be allowed to join the ISR | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1430414139 |
|---|
|
| core | Done |
KIP-904: Kafka Streams - Guarantee subtractor is called before adder if key has not changed | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-12446 |
|---|
|
| Streams | Done (system test missing) |
| KIP-907: Add Boolean Serde to public interface884: Add config to configure KafkaClientSupplier in Kafka Streams | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1439514722 |
|---|
|
| streamsStreams | Done |
| KIP-887911: Add ConfigProvider to make use of environment variablessource tag to Mirror source metric | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1437614740 |
|---|
|
| clientsconnect | PR availableDone |
| KIP-889914: DSL Processor Semantics for Versioned State Stores | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1449114834 |
|---|
|
| Streams | streamsDone |
KIP- 893: The Kafka protocol should support nullable structs915: Txn and Group Coordinator Downgrade Foundation | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-1442514869 |
|---|
|
| core | Done |