KIP | Comment |
---|
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-113: Support replicas movement between log directories | |
KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback | |
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-135 : Send of null key to a compacted topic should throw non-retriable error back to user | |
KIP 141 - ProducerRecord & SourceRecord: Add timestamp constructors | |
KIP-142: Add ListTopicsRequest to efficiently list all the topics in a cluster | |
KIP-145 - Expose Record Headers in Kafka Connect | builds on KIP-82 (would be ideal to make 0.11 release so it can go out as one, but not mandatory) |
KIP-147: Add missing type parameters to StateStoreSupplier factories and KGroupedStream/Table methods | |
KIP-148: Add a connect timeout for client | Draft |
KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner | |
KIP-150 - Kafka-Streams Cogroup | |
KIP-152 - Improve diagnostics for SASL authentication failures | |
KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics | |
KIP-159: Introducing Rich functions to Streams | |
KIP-160: Augment KStream.print() to allow users pass in extra parameters in the printed string | |
KIP-161: streams record processing exception handlers | |
KIP-162: Enable topic deletion by default | |