| KIP | Comment |
|---|
| KIP-6 - New reassignment partition logic for rebalancing | Needs more detail |
| KIP-10 - Running Producer, Consumers and Brokers on Mesos |
|
| KIP-14 - Tools standardization |
|
| KIP-17 - Add HighwaterMarkOffset to OffsetFetchResponse |
|
| KIP-23 - Add JSON/CSV output and looping options to ConsumerGroupCommand |
|
| KIP-27 - Conditional Publish |
|
| KIP-30 - Allow for brokers to have plug-able consensus and meta data storage sub systems |
|
| KIP-37 - Add Namespaces to Kafka |
|
| KIP-39: Pinning controller to broker |
|
| KIP-44 - Allow Kafka to have a customized security protocol |
|
| KIP-46 - Self Healing |
|
| KIP-47 - Add timestamp-based log deletion policy |
|
| KIP-49 - Fair Partition Assignment Strategy |
|
| KIP-53 - Add custom policies for reconnect attempts to NetworkdClient |
|
| KIP-59: Proposal for a kafka broker command |
|
| KIP-64 -Allow underlying distributed filesystem to take over replication depending on configuration |
|
| KIP-68 Add a consumed log retention before log retention |
|
| KIP-69 - Kafka Schema Registry | Draft |
| KIP-76 Enable getting password from executable rather than passing as plaintext in config files |
|
| KIP-87 - Add Compaction Tombstone Flag | Possibly displaced by KIP-82 |
| KIP-95: Incremental Batch Processing for Kafka Streams |
|
| KIP-159: Introducing Rich functions to Streams |
|
| KIP-260: add primary join operation for Stream-Stream join (WIP) | Draft |
KIP-269: Substitution Within Configuration Values |
|
| KIP-311: Async processing with dynamic scheduling in Kafka Streams |
|
| KIP-314: KTable to GlobalKTable Bi-directional Join |
|
| KIP-326: Schedulable KTable as Graph source |
|
| KIP-349: Priorities for Source Topics | Functionality can be realized with existing API although at a lower level. |
| KIP-335: Consider configurations for KafkaStreams |
|
| KIP-362: Support Dynamic Session Window |
|
| KIP-378: Enable Dependency Injection for Kafka Streams handlers |
|
| KIP-408: Add asynchronous processing to Kafka Streams |
|
| KIP-419: Safely notify Kafka Connect SourceTask is stopped |
|
| KIP-422: Add support for client quota configuration in the Kafka Admin Client | KIP-546 added the necessary APIs instead |
| KIP-457: Add DISCONNECTED status to Kafka Streams |
|
| KIP-459: Improve KafkaStreams#close |
|
| KIP-463: Auto-configure non-default Serdes passed alongside the TopologyBuilder |
|
| KIP-611: Improved Handling of Abandoned Connectors and Tasks |
|
| KIP-645: Replace Windows with a proper interface | Still nice to have, just not as important as I thought. |
| KIP-634: Complementary support for headers and record metadata in Kafka Streams DSL | KIP-820 offers a workaround, and potential DSL v2 could replace the proposal. |
| KIP-657: Add Customized Kafka Streams Logo |
|
| KIP-883: Add isDeleted flag when stopping a connector |
|
| KIP-901: Add connectorDeleted flag when stopping tasks |
|