KIP | Comment |
---|
KIP-59: Proposal for a kafka broker command | Sent 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 Connect | builds 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-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 deserialization | Voting 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-227 - Introduce Incremental FetchRequests to Increase Partition Scalability | |
KIP-228 Negative record timestamp support | |
KIP-231: Improve the Required ACL of ListGroups API | Voting in progress (pending one more binding votes) |
KIP-232: Detect outdated metadata using per-partition leaderEpoch field | |
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-245: Use Properties instead of StreamsConfig in KafkaStreams constructor | Voting in progress |
KIP-248 - Create New ConfigCommand That Uses The New AdminClient | |
KIP-249: Add Delegation Token Operations to KafkaAdminClient | Voting in progress |
KIP-250 Add Support for Quorum-based Producer Acknowledgment | |