KIP | State | Comment |
---|
KIP-81: Bound Fetch memory usage in the consumer | Discuss | |
KIP-82 - Add Record Headers | Discuss | |
KIP-86: Configurable SASL callback handlers | Discuss | |
KIP-87 - Add Compaction Tombstone Flag | Discuss | Possibly displaced by KIP-82 |
KIP-91 Provide Intuitive User Timeouts in The Producer | In Prep | |
KIP-95: Incremental Batch Processing for Kafka Streams | Discuss | |
KIP-110: Add Codec for ZStandard Compression | Discuss | |
KIP-111: Kafka should preserve the Principal generated by the PrincipalBuilder while processing the request received on socket channel, on the broker. | Discuss | |
KIP-112: Handle disk failure for JBOD | Discuss | |
KIP-113: Support replicas movement between log directories | Discuss | |
KIP-114: KTable materialization and improved semantics | Discuss | |
KIP-117: Add a public AdminClient API for Kafka admin operations | Discuss | |
KIP-120: Cleanup Kafka Streams builder API | Discuss | |
KIP-122: Add Reset Consumer Group Offsets tooling | Discuss | |
KIP-123: Allow per stream/table timestamp extractor | Discuss | |
KIP-124 - Request rate quotas | Discuss | |
KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback | Discuss | |
KIP-126 - Allow KafkaProducer to batch based on uncompressed size | Discuss | |
KIP-128: Add ByteArrayConverter for Kafka Connect | Discuss | |
KIP-129: Streams Exactly-Once Semantics | Discuss | |
KIP-131 - Add access to OffsetStorageReader from SourceConnector | DiscussDisucss | |