| KIP | JIRA | Component | Comment |
|---|
| KIP-465: Add Consolidated Connector Endpoint to Connect REST API | | Connect |
|
| KIP-462: Use local thread id for KStreams | | Streams |
|
| KIP-461: Improve Replica Fetcher behavior at handling partition failure | | Core |
|
| KIP-458: Connector Client Config Override Policy | | Connect |
|
| KIP-454: Expansion of the ConnectClusterState interface | | Connect |
|
| KIP-453: Add close() method to RocksDBConfigSetter | | Streams |
|
| KIP-449: Add connector contexts to log messages in Connect workers | KAFKA-3816 | Connect |
|
| KIP-445: In-memory Session Store | KAFKA-8029 | Streams |
|
| KIP-443: Return to default segment.ms and segment.index.bytes in Streams repartition topics | | Streams |
|
| KIP-442: Return to default max poll interval in Streams | | Streams |
|
| KIP-436: Add a metric indicating start time | KAFKA-7992 | Core |
|
| KIP-430 - Return Authorized Operations in Describe Responses | KAFKA-7922 | Core |
|
| KIP-428: Add in-memory window store | KAFKA-4730 | Streams |
|
| KIP-427: Add AtMinIsr topic partition category (new metric & TopicCommand option) | KAFKA-7904 | Core |
|
| KIP-425: Add some Log4J Kafka Appender Properties for Producing to Secured Brokers | KAFKA-7896 | Core |
|
| KIP-421: Support resolving externalized secrets in AbstractConfig | KAFKA-7847 | Core |
|
| KIP-417: Allow JmxTool to connect to a secured RMI port | KAFKA-7455 | Core |
|
| KIP-415: Incremental Cooperative Rebalancing in Kafka Connect | KAFKA-5505 | Connect |
|
| KIP-411: Make default Kafka Connect worker task client IDs distinct | KAFKA-5061 | Connect |
|
| KIP-402: Improve fairness in SocketServer processors | KAFKA-7719, KAFKA-7730 | Core | Partially implemented in 2.2. |
| KIP-361: Add Consumer Configuration to Disable Auto Topic Creation | KAFKA-7320 | Core |
|
| KIP-351: Add --under-min-isr option to describe topics command | KAFKA-7236 | Core |
|
| KIP-345: Introduce static membership protocol to reduce consumer rebalances | KAFKA-7018, KAFKA-7610, KAFKA-7728, KAFKA-8224 | Core, Clients | Partially implemented in 2.3 (can already be used) |
| KIP-339: Create a new IncrementalAlterConfigs API | KAFKA-7466 | Core | Voted on a while ago, but first implemented in 2.3. |
| KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde | KAFKA-6161 | Streams |
|
| KIP-313: Add KStream.flatTransform and KStream.flatTransformValues | | Streams | Partially implemented since 2.2. |
| KIP-307: Allow to define custom processor names with KStreams DSL | KAFKA-6958 | Streams | Partially implemented in 2.3 (no public API improvements yet) |
| KIP-258: Allow to Store Record Timestamps in RocksDB | KAFKA-3522 and KAFKA-8382 | Streams | Partially implemented in 2.3 |
| KIP-354: Add a Maximum Log Compaction Lag | KAFKA-7321 | Core |
|