Child pages
  • Kafka Improvement Proposals
267 more child pages

Versions Compared


  • This line was added.
  • This line was removed.
  • Formatting was changed.


KIP round-up

Next KIP Number: 267268

Use this number as the identifier for your KIP and increment this value.


KIP-59: Proposal for a kafka broker commandSent 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-186: Increase offsets retention default to 7 days 
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 deserializationVoting in progress
KIP-209: Connection String Support 
KIP-211: Revise Expiration Semantics of Consumer Group Offsets 
KIP-212: Enforce set of legal characters for connector names 
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 JoinsDiscussion
KIP-231: Improve the Required ACL of ListGroups APIVoting in progress (pending one more binding votes)
KIP-232: Detect outdated metadata using per-partition leaderEpoch fieldVoting in progress
KIP-234: add support for getting topic defaults from AdminClient 
KIP-235: Add DNS alias support for secured connection 
KIP-236: Interruptible Partition Reassignment 
KIP-240: AdminClient.listReassignments() AdminClient.describeReassignments() 
KIP-242: Mask password in Kafka Connect Rest API response 
KIP-244: Add Record Header support to Kafka Streams 
KIP-248 - Create New ConfigCommand That Uses The New AdminClientVoting in progress (pending on more binding votes)
KIP-249: Add Delegation Token Operations to KafkaAdminClientVoting in progress
KIP-250 Add Support for Quorum-based Producer Acknowledgment 
KIP-251: Allow timestamp manipulation in Processor API 
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-255: OAuth Authentication via SASL/OAUTHBEARER 
KIP-257 - Configurable Quota Management 
KIP-258: Allow to Store Record Timestamps in RocksDBDraft
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 

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() 
KIP-267: Add Processor Unit Test Support to Kafka Streams Test Utils 

Dormant/inactive KIPs