KIP | Comment |
---|
KIP-59: Proposal for a kafka broker command | Sent emails to Dev discussion group. Work tracked under KAFKA-3663. |
KIP-110: Add Codec for ZStandard Compression | |
KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback | |
KIP-131 - Add access to OffsetStorageReader from SourceConnector | |
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-148: Add a connect timeout for client | |
KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics | |
KIP-159: Introducing Rich functions to Streams | |
KIP-165: Extend Interactive Queries for return latest update timestamp per key | |
KIP-166 - Add a tool to make amounts of replicas and leaders on brokers balanced | |
KIP-169 - Lag-Aware Partition Assignment Strategy | |
KIP-176: Remove deprecated new-consumer option for tools | |
KIP-178: Size-based log directory selection strategy | |
KIP-185: Make exactly once in order delivery the default producer setting | |
KIP-193: Add SchemaBuilder.from(Schema) | |
KIP-199: Add Kafka Connect offset tool | |
KIP-201: Rationalising Policy interfaces | |
KIP-206: Add support for UUID serialization and deserialization | Voting in progress |
KIP-209: Connection String Support | |
KIP-213 Support non-key joining in KTable | |
KIP-216: IQ should throw different exceptions for different errors | |
KIP-217: Expose a timeout to allow an expired ZK session to be re-created | |
KIP-221: Repartition Topic Hints in Streams | |
KIP-228 Negative record timestamp support | |
KIP 230: Name Windowing Joins | Discussion |
KIP-231: Improve the Required ACL of ListGroups API | Voting in progress (pending one binding +1) |
KIP-232: Detect outdated metadata using per-partition leaderEpoch field | Voting in progress |
KIP-234: add support for getting topic defaults from AdminClient | |
KIP-235: Add DNS alias support for secured connection | Voting in progress |
KIP-236: Interruptible Partition Reassignment | |
KIP-240: AdminClient.listReassignments() AdminClient.describeReassignments() | |
KIP-242: Mask password in Kafka Connect Rest API response | |
KIP-248 - Create New ConfigCommand That Uses The New AdminClient | Voting in progress (pending on more binding votes) |
KIP-250 Add Support for Quorum-based Producer Acknowledgment | |
KIP-252 - Extend ACLs to allow filtering based on ip ranges and subnets | |
KIP-253: Support in-order message delivery with partition expansion | |
KIP-254: JsonConverter Exception Handeling | |
KIP-258: Allow to Store Record Timestamps in RocksDB | depends on KIP-268 |
KIP-259: Improve Streams DSL Timestamp Propagation Semantics | |
KIP-260: add primary join operation for Stream-Stream join (WIP) | Draft |
KIP-262: Metadata should include number of state stores for task | depends on KIP-268 |
KIP-263: Allow broker to skip sanity check of inactive segments on broker startup | |
KIP-264: Add a consumer metric to record raw fetch size | |
KIP-266: Add TimeoutException to KafkaConsumer#position() | Accepted |
KIP-269: Substitution Within Configuration Values | requirement for KIP-255 |
KIP-271: Add NetworkClient redirector | Discussion |
KIP-273: Kafka to support using ETCD beside Zookeeper | Discussion |
KIP-275 - Indicate "isClosing" in the SinkTaskContext | Voting in progress |
KIP-278 - Add version option to Kafka's commands | Voting in progress |
KIP-280: Enhanced log compaction | Discussion |
KIP-281: ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User | Voting in progress |
KIP-285: Connect Rest Extension Plugin | Voting in progressAccepted |
KIP-287: Support partition and processor expansion for stateful processing jobs | Discussion |
KIP-289: Improve the default group id behavior in KafkaConsumer | Discussion |
KIP-291: Have separate queues for control requests and data requests | Discussion |
KIP-293 Add new metrics for consumer/replication fetch requests | Discussion |
KIP-295 Add Streams Configuration Allowing for Optional Topology Optimization | Accepted |
KIP-296: Add connector level configurability for producer/consumer client configs | Discussion |
KIP-298: Error Handling in Connect | Voting in progress |
KIP-300: Add Windowed KTable API in StreamsBuilder | Discussion |
KIP-301: Schema Inferencing for JsonConverter | Discussion |
KIP-302 - Enable Kafka clients to use all DNS resolved IP addresses | Discussion |
KIP-303: Add Dynamic Routing in Streams Sink | Discussion |
KIP-304: Connect runtime mode improvements for container platforms | Discussion |
KIP-305: Add Connect primitive number converters | Discussion |
KIP-306: Configuration for Delaying Response to Failed Authentication | Discussion |