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 172: Add regular-expression topic support for sink connector | |
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 deserialization | Voting in progress |
KIP-208: Add SSL support to Kafka Connect REST interface | |
KIP-209: Connection String Support | |
KIP-210 - Provide for custom error handling when Kafka Streams fails to produce | Voting in progress |
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-218: Make KafkaFuture.Function java 8 lambda compatible | |
KIP-219 - Improve quota communication | |
KIP-221: Repartition Topic Hints in Streams | |
KIP-222 - Add "describe consumer group" to KafkaAdminClient | Voting in progress |
KIP-223 - Add per-topic min lead and per-partition lead metrics to KafkaConsumer | |
KIP-225 - Use tags for consumer “records.lag” metrics | |
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 API | |
KIP-232: Detect outdated metadata by adding ControllerMetadataEpoch 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 | |