This page is for KIPs that are no longer under active development but may be revived in the future. These are generally KIPs that had to be suspended for some reason, for example because the author was not able to continue it themselves or because there was insufficient interest/support from the community.

If you would like to revive a dormant/inactive KIP listed here, please reach out to the original author to ask if you can pick it up. If they don't respond within a few days, feel free to assign the Jira ticket to yourself and proceed with the KIP. We ask that you continue the discussion on the original KIP thread if possible, even if you've changed it significantly, so that we can read and reference what's been said already.

For KIPs that were intentionally dropped/discarded, see the Discarded KIPs subpage

Please insert new rows in sorted order (ascending by KIP number).

KIPComment
KIP-6 - New reassignment partition logic for rebalancingNeeds 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 RegistryDraft
KIP-76 Enable getting password from executable rather than passing as plaintext in config files
KIP-87 - Add Compaction Tombstone FlagPossibly 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 ClientKIP-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 interfaceStill nice to have, just not as important as I thought.
KIP-634: Complementary support for headers and record metadata in Kafka Streams DSLKIP-820 offers a workaround, and potential DSL v2 could replace the proposal.
KIP-657: Add Customized Kafka Streams Logo
  • No labels