Page History

...

KIP	Comment
KIP-81: Bound Fetch memory usage in the consumer
KIP-82 - Add Record Headers
KIP-86: Configurable SASL callback handlers
KIP-87 - Add Compaction Tombstone Flag	Possibly displaced by KIP-82
KIP-91 Provide Intuitive User Timeouts in The Producer
KIP-95: Incremental Batch Processing for Kafka Streams
KIP-110: Add Codec for ZStandard Compression
KIP-111: Kafka should preserve the Principal generated by the PrincipalBuilder while processing the request received on socket channel, on the broker.
KIP-112: Handle disk failure for JBOD
KIP-113: Support replicas movement between log directories
KIP-114: KTable materialization and improved semantics
KIP-117: Add a public AdminClient API for Kafka admin operations
KIP-120: Cleanup Kafka Streams builder API
KIP-122: Add Reset Consumer Group Offsets tooling
KIP-123: Allow per stream/table timestamp extractor
KIP-124 - Request rate quotas
KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback
KIP-126 - Allow KafkaProducer to batch based on uncompressed size
KIP-129: Streams Exactly-Once Semantics
KIP 130: Expose states of active tasks to KafkaStreams public API	May be semi-overlapped with KIP-120
KIP-131 - Add access to OffsetStorageReader from SourceConnector
KIP-132: Augment KStream.print to allow extra parameters in the printed string
KIP-133: Describe and Alter Configs protocol	Draft
KIP-134: Delay initial consumer group rebalance
KIP-135 : Send of null key to a compacted topic should throw non-retriable error back to user

Dormant/inactive KIPs

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-18 - JBOD Support
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

...