Child pages
  • Kafka Improvement Proposals
245 more child pages

Versions Compared


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


KIP-59: Proposal for a kafka broker commandSent emails to Dev discussion group. Work tracked under KAFKA-3663.
KIP-86: Configurable SASL callback handlers 
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-145 - Expose Record Headers in Kafka Connectbuilds on KIP-82 (would be ideal to make 0.11 release so it can go out as one, but not mandatory)
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-174 - Deprecate and remove internal converter configs in WorkerConfig

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-208: Add SSL support to Kafka Connect REST interface


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-219 - Improve quota communication

KIP-221: Repartition Topic Hints in Streams 
KIP-222 - Add "describe consumer group" to KafkaAdminClientConsumer Group operations to Admin APIVoting in progress
KIP-226 - Dynamic Broker Configuration 
KIP-227 - Introduce Incremental FetchRequests to Increase Partition Scalability 
KIP-228 Negative record timestamp support 
KIP-229: DeleteGroups API 
KIP-231: Improve the Required ACL of ListGroups APIVoting in progress
KIP-232: Detect outdated metadata using per-partition leaderEpoch field 
KIP-233: Simplify StreamsBuilder#addGlobalStore 
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-237: More Controller Health Metrics 
KIP-239 Add queryableStoreName() to GlobalKTable 
KIP-240: AdminClient.listReassignments() AdminClient.describeReassignments() 
KIP-243: Make ProducerConfig and ConsumerConfig constructors public   
KIP-244: Add Record Header support to Kafka Streams 
KIP-245: Use Properties instead of StreamsConfig in KafkaStreams constructorVoting in progress