KIP | Comment |
---|
KIP-504 - Add new Java Authorizer Interface |
|
KIP-503: Add metric for number of topics marked for deletion |
|
KIP-502: Connect SinkTask.put(...) to specify ArrayList<SinkRecord> in Signature |
|
KIP-500: Replace ZooKeeper with a Self-Managed Metadata Quorum |
|
KIP-499: Create a controller RPC for changing configurations |
|
KIP-495: Dynamically Adjust Log Levels in Connect | Sent mail to dev discussion group. |
KIP-494: Connect REST Endpoint for Transformations (SMTs) and other Plugins |
|
KIP-59: Proposal for a kafka broker command | Sent emails to Dev discussion group. Work tracked under KAFKA-3663. |
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-166 - Add a tool to make amounts of replicas and leaders on brokers balanced |
|
KIP-169 - Lag-Aware Partition Assignment Strategy |
|
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-209: Connection String Support |
|
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-228 Negative record timestamp support | Voting in progress |
KIP-234: add support for getting topic defaults from AdminClient |
|
KIP-236: Interruptible Partition Reassignment | Discussion |
KIP-240: AdminClient.listReassignments() AdminClient.describeReassignments() |
|
KIP-242: Mask password in Kafka Connect Rest API response |
|
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 | Discussion |
KIP-254: JsonConverter Exception Handeling |
|
KIP-259: Improve Streams DSL Timestamp Propagation Semantics |
|
KIP-260: add primary join operation for Stream-Stream join (WIP) | Draft |
KIP-264: Add a consumer metric to record raw fetch size | Voting in progress |
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-280: Enhanced log compaction | Discussion |
KIP-291: Separating controller connections and requests from the data plane | Accepted |
KIP-293 Add new metrics for consumer/replication fetch requests | Voting in progress |
KIP-296: Add connector level configurability for producer/consumer client configs | Discussion |
KIP-301: Schema Inferencing for JsonConverter | Discussion |
KIP-304: Connect runtime mode improvements for container platforms | Discussion |
KIP-314: KTable to GlobalKTable Bi-directional Join | Discussion |
KIP-315: Stream Join Sticky Assignor | Discussion |
KIP-316: Command-line overrides for ConnectDistributed worker properties | Discussion |
KIP-317: Add end-to-end data encryption functionality to Apache Kafka | Discussion |
KIP-325: Extend Consumer Group Command to Show Beginning Offsets | Voting in Progress345 |
KIP-326: Schedulable KTable as Graph source | Discussion |
KIP-333: Add faster mode of rebalancing | Discussion |
KIP-334 - Include partitions in exceptions raised during consumer record deserialization/validation |
|
KIP-335: Consider configurations for KafkaStreams | Discussion |
KIP-347: Enable batching in FindCoordinatorRequest | Discussion |
KIP-348 Eliminate null from SourceTask#poll() |
|
KIP-350: Allow kafka-topics.sh to take brokerid as parameter to show partitions associated with it |
|
KIP-356: Add KafkaConsumer fetch-error-rate and fetch-error-total metrics | Discussion |
KIP-360: Improve handling of unknown producer | Discussion |
KIP-362: Support Dynamic Session Window | Discussion |
KIP-363: Allow performance tools to print final results to output file | Discussion |
KIP-369: Alternative Partitioner to Support "Always Round-Robin" Selection | Accepted |
KIP-370: Remove Orphan Partitions | Discussion |
KIP-373: Allow users to create delegation tokens for other users | Discussion |
KIP-375: Kafka Clients - make Metadata#TOPIC_EXPIRY_MS configurable | Discussion |
KIP-378: Enable Dependency Injection for Kafka Streams handlers | Discussion |
KIP-379: Multiple Consumer Group Management | Accepted |
KIP-381: Connect: Tell about records that had their offsets flushed in callback | Voting in progress (restarted 18th January 2019, due to no votes in first attempt) |
KIP-383: Pluggable interface for SSL Factory | Voting in progress |
KIP-384: Add config for incompatible changes to persistent metadata | Discussion |
KIP-385: Avoid throwing away prefetched data | Discussion |
KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer | Discussion |
KIP-388: Add observer interface to record request and response | Discussion |
KIP-389: Introduce a configurable consumer group size limit | Accepted |
KIP-390: Allow fine-grained configuration for compression | Discussion, JIRA exists with pull-request |
KIP-391: Allow Producing with Offsets for Cluster Replication | Discussion, JIRA exists with pull-request |
KIP-392: Allow consumers to fetch from closest replica | Discussion |
KIP-395: Encypt-then-MAC Delegation token metadata |
|
KIP-396: Add Commit/List Offsets Operations to AdminClient | Discussion |
KIP-397: Add methods to override fetch offsets based on timestamp | Discussion |
KIP-398: Support reading trust store from classpath | Discussion |
KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions | Discussion |
KIP-400: Improve exit status in case of errors in ConsoleProducer | Discussion |
KIP-401: TransformerSupplier/ProcessorSupplier StateStore connecting | Voting in progress |
KIP-403: Increase ProducerPerformance precision by using nanoTime | Draft |
KIP-405: Kafka Tiered Storage | Discussion |
KIP-406: GlobalStreamThread should honor custom offset policy. | Discussion |
KIP-407: Kafka Connect support override worker kafka api configuration with connector configuration that post by rest api |
|
KIP-408: Add asynchronous processing to Kafka Streams | Discussion |
KIP-409: Allow creating under-replicated topics and partitions |
|
KIP-410: Add metric for request handler thread pool utilization by request type | Discussion |
KIP-416: Notify SourceTask of ACK'd offsets, metadata | Discussion |
KIP-418: A method-chaining way to branch KStream | Discussion, JIRA exists with pull-request |
KIP-419: Safely notify Kafka Connect SourceTask is stopped | Voting in progress, JIRA exists with pull request |
KIP-421: Support resolving externalized secrets in AbstractConfig | Accepted |
KIP-422: Add support for client quota configuration in the Kafka Admin Client | Discussion, JIRA exists with pull-request |
KIP-423: Add JoinReason to Consumer Join Group Protocol | Discussion |
KIP-424: Allow suppression of intermediate events based on wall clock time | Discussion |
KIP-426: Persist Broker Id to Zookeeper | Discussion |
KIP-431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter | Voting in progress, JIRA exists with pull-request |
KIP-434: Add Replica Fetcher and Log Cleaner Count Metrics | Discussion |
KIP-435: Internal Partition Reassignment Batching | Discussion |
KIP-437: Custom replacement for MaskField SMT | Voting in progress, JIRA exists with pull-request |
KIP-438: Expose task, connector IDs in Connect API | Discussion |
KIP-439: Cleanup built-in Store interfaces | Discussion |
KIP-440: Extend Connect Converter to support headers | Voting in progress |
KIP-441: Smooth Scaling Out for Kafka Streams | Discussion |
KIP-444: Augment metrics for Kafka Streams | Discussion |
KIP-448: Add State Stores Unit Test Support to Kafka Streams Test Utils | Discussion |
KIP-450: Sliding Window Aggregations in the DSL | Discussion |
KIP-452: Tool to view cluster status | Discussion, JIRA exists |
KIP-457: Add DISCONNECTED status to Kafka Streams | Discussion |
KIP-459: Improve KafkaStreams#close | Discussion |
KIP-463: Auto-configure non-default Serdes passed alongside the TopologyBuilder | Under discussion |
KIP-466: Add support for List<T> serialization and deserialization | Voting in progress |
KIP-468: Avoid decompression of record when validate record at server in the scene of inPlaceAssignment . | Under discussion |
KIP-470: TopologyTestDriver test input and output usability improvements | Under discussion |
KIP-471: Expose RocksDB Metrics in Kafka Streams | Accepted |
KIP-473: Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers | Under Discussion |
KIP-474: To deprecate WindowStore#put(key, value) | Accepted |
KIP-475: New Metrics to Measure Number of Tasks on a Connector | Accepted |
KIP-477: Add PATCH method for connector config in Connect REST API | Under Discussion |
KIP-478 - Strongly typed Processor API | Under Discussion |
KIP-479: Add Materialized to Join | Accepted |
KIP-480: Sticky Partitioner | Accepted |
KIP-481: SerDe Improvements for Connect Decimal type in JSON | Under Discussion |
KIP-482: Optional fields in the Kafka Protocol |
|
KIP-487: Automatic Topic Creation on Producer | Under Discussion |
KIP-489: Kafka Consumer Record Latency Metric | Under Discussion |
KIP-490: New metric to count offsets expired without being consumed by a consumer group | Under discussion |
KIP-491: Preferred Leader Deprioritized List (Temporary Blacklist) | Under discussion |
KIP-498: Add client-side configuration for maximum response size to protect against OOM | Sent emails to Dev discussion group. Work tracked under KAFKA-4090. |
KIP-499 - Unify connection name flag for command line tool | Under discussion |