This page describes a proposed Kafka Improvement Proposal (KIP) process for proposing a major change to Kafka.
...
...
...
...
Use this number as the identifier for your KIP and increment this value.
...
KIP (please keep this sorted by KIP number) | Release |
---|
KIP- |
651 - Support PEM format for SSL certificates and private key2.7.0 (WIP) | KIP-648 Renaming getter method for Interactive Queries | 2.7632: Add DirectoryConfigProvider2.7627: Expose Trogdor-specific JMX Metrics for Tasks and Agents2.7.0 (WIP) | KIP-626: Rename StreamsConfig config variable name | 2.7623: Add "internal-topics" option to streams application reset tool2.7.0 (WIP)621: Deprecate and replace DescribeLogDirsResult.all() and .values()2.7.0 (WIP) | KIP-620 Deprecate ConsumerConfig#addDeserializerToConfig and ProducerConfig#addSerializerToConfig | 2 (WIP)617: Allow Kafka Streams State Stores to be iterated backwards2 (WIP)616: Rename implicit Serdes instances in kafka-streams-scala2.7.0 (WIP613: Add end-to-end latency metrics to Streams2.6.0 (partially implemented), remainder 2.7.0 (WIP612: Ability to Limit Connection Creation Rate on Brokers2.7.0 (WIP) | KIP-610: Error Reporting in Sink Connectors | 2.6608: Expose Kafka Metrics in Authorizer2 (WIP)607: Add Metrics to Kafka Streams to Report Properties of RocksDB2 (WIP)606: Add Metadata Context to MetricsReporter2.6605: Expand Connect Worker Internal Topic Settings2.6.0604: Remove ZooKeeper Flags from the Administrative Toolsone part in 2.6.0, most parts scheduled for 3.0 | KIP-602: Change default value for client.dns.lookup | 2.6601: Configurable socket connection timeout2599: Throttle Create Topic, Create Partition and Delete Topic Operations2 (WIP597: MirrorMaker2 internal topics Formatters2WIPdeprecation) 4.0.0 (removal) |
KIP- |
594: Expose output topic names from TopologyTestDriver2.6590: Redirect Zookeeper Mutation Protocols to The Controller2 (WIP)589 Add API to update Replica state in Controller2 (WIP)588: Allow producers to recover gracefully from transaction timeouts2 (WIP)586: Deprecate commit records without record metadata2.6585: Filter and Conditional SMTs2.6584: Versioning scheme for features2 (WIP)580: Exponential Backoff for Kafka Clients2 (WIP)KIP-577: Allow HTTP Response Headers to be Configured for Kafka Connect | 2.6.0 |
KIP-574: CLI Dynamic Configuration with file input | 2573: Enable TLSv1.3 by default2572: Improve timeouts and retries 2WIPcompleted) 3.6.0 (partially implemented) |
KIP- |
571 option to force remove members in StreamsResetter2570: Add leader epoch in StopReplicaRequest2.6569: DescribeConfigsResponse - Update the schema to include additional metadata information of the field2568: Explicit rebalance triggering on the Consumer2.6562: Allow fetching a key from a single partition rather than iterating over all the stores on an instance20 559: Make the Kafka Protocol Friendlier with L7 Proxies2558: Track the set of actively used topics by connectors in Kafka Connect2.5.0557 emit on change support for Kafka StreamsImplemented for KTable source nodes in 2.6.0, full implementation planned for subsequent releases. | KIP-555: Deprecate direct Zookeeper access in Kafka administrative tools | 2554 Add Broker-side SCRAM Config API2.7553: Disable all SSL protocols except TLSV1.2 by default.2551: Expose disk read and write metrics2546: Add Client Quota APIs to the Admin Client2 (describe/alter), remainder pending (resolve)545: support automated consumer offset sync across clusters in MM 22KIP-544: Make metrics exposed via JMX configurable | - new metric & request log attribute 4.0.0 - actual removal |
2.5.0543: Expand ConfigCommand's non-ZK functionality2541: Create a fetch.max.bytes configuration for the broker2538: Add a metric tracking the number of open connections with a given SSL cipher type2.5.0 | KIP-537: Increase default zookeeper session timeout | 2.5535: Allow state stores to serve stale reads during rebalance2534: Reorganize checkpoint system in log cleaner to per partition WIP533 default api timeout to AdminClient2532: Broker Consumer Lag metrics in size and timeWIP | KIP-531: Drop support for Scala 2.11 in Kafka 2.5 | Initial version in 2, remainder in later release WIP530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'2.5528: Deprecate PartitionGrouper configuration and interface2.4.0 | KIP-527: Add VoidSerde to Serdes | 2.5.0 |
KIP-526: Reduce Producer Metadata Lookups for Large Number of Topics | 2.5.0 |
KIP-525 - Return topic metadata and configs in CreateTopics response | 2.4.0 |
KIP-524: Allow users to choose config source when describing configs | 2.5.0 |
KIP-523: Add KStream#toTable to the Streams DSL | 2.5.0 |
KIP-521: Enable redirection of Connect's log4j messages to a file by default | 2519: Make SSL context/engine configuration extensible2.6518: Allow listing consumer groups per state2.6517: Add consumer metrics to observe user poll behavior2515: Enable ZK client to use the new TLS supported authentication2.5514:Add a bounded flush() API to Kafka Producer2.5.0 | KIP-511: Collect and Expose Client's Name and Version in the Brokers | 2.4.0 (protocol) / 2.5.0 (metric) |
KIP-507: Securing Internal Connect REST Endpoints | 2.4.0 |
KIP-504 - Add new Java Authorizer Interface | 2.4.0 |
KIP-503: Add metric for number of topics marked for deletion | 2.4.0 |
KIP-501: Avoid out-of-sync or offline partitions when follower fetch requests not processed in time | WIP |
KIP-500: Replace ZooKeeper with a Self-Managed Metadata Quorum | KIP-497: Add inter-broker API to alter ISR | 2.7.0 (WIP) |
KIP-496: Administrative API to delete consumer offsets | 2.4.0 |
KIP-495: Dynamically Adjust Log Levels in Connect | 2.4.0 |
KIP-492: Add java security providers in Kafka Security config | 2.4.0 |
KIP-488: Clean up Sum,Count,Total Metrics | 2.4.0 |
KIP-484: Expose metrics for group and transaction metadata loading duration | 2.4.0 |
KIP-482: The Kafka Protocol should Support Optional Tagged Fields | 2.4.0 |
KIP-481: SerDe Improvements for Connect Decimal type in JSON | 2480: Sticky Partitioner2.4479: Add StreamJoined config object to Join2.4478 - Strongly typed Processor APIWIP476: Add Java AdminClient Interface2.4.0475: New Metrics to Measure Number of Tasks on a Connector2.4474: To deprecate WindowStore#put(key, value)2.4471: Expose RocksDB Metrics in Kafka Streams2.4.0 (partially implemented; completion blocked) | KIP-470: TopologyTestDriver test input and output usability improvements | 2.4.0 |
KIP-467: Augment ProduceResponse error messaging for specific culprit records | 2.4.0 (partially implemented) / 2.5466 support for List<T> serialization and deserialization2.7.0 (WIP) | KIP-465: Add Consolidated Connector Endpoint to Connect REST API | 2.3.464: Defaults for AdminClient#createTopic2.4.462: Use local thread id for KStreams2.3461: Improve Replica Fetcher behavior at handling partition failure2.3.460: Admin Leader Election RPC2.4.458: Connector Client Config Override Policy2.3455: Create an Administrative API for Replica Reassignment2.4.0 (API/broker logic) 2.5.0 (tools changes) | KIP-454: Expansion of the ConnectClusterState interface | 2.3.0 |
KIP-453: Add close() method to RocksDBConfigSetter | 2.3450: Sliding Window Aggregations in the DSLWIP449: Add connector contexts to log messages in Connect workers 2447: Producer scalability for exactly once semantics2.5.0 (broker, consumer, producer changes implemented) / 2.446 changelog topic configuration to KTable suppress2.6445: In-memory Session Store2.3444: Augment metrics for Kafka Streams2.4.0 (partially implemented) / 2.5.0 (partially implemented) / 2.6443: Return to default segment.ms and segment.index.bytes in Streams repartition topics2.3442: Return to default max poll interval in Streams2.3441: Smooth Scaling Out for Kafka Streams2.6440: Extend Connect Converter to support headers2.4.437: Custom replacement for MaskField SMT2.6436: Add a metric indicating start time2.3434: Add Replica Fetcher and Log Cleaner Count Metrics2.4.0 | KIP-430 - Return Authorized Operations in Describe Responses | 2.3429: Kafka Consumer Incremental Rebalance Protocol2428: Add in-memory window store2.3.427: Add AtMinIsr topic partition category (new metric & TopicCommand option)2.3425: Add some Log4J Kafka Appender Properties for Producing to Secured Brokers2.3421: Support resolving externalized secrets in AbstractConfig2.3.420: Add Single Value Fetch in Session Stores2.2418: A method-chaining way to branch KStream2.7417: Allow JmxTool to connect to a secured RMI port2.415: Incremental Cooperative Rebalancing in Kafka Connect2.KIP-414: Expose Embedded ClientIds in Kafka Streams | 2.2.0 |
KIP-412: Extend Admin API to support dynamic application log levels | 2.4.0 |
KIP-411: Make default Kafka Connect worker task client IDs distinct | 2.3402: Improve fairness in SocketServer processors2.2.0 (partially implemented) / 2.3401: TransformerSupplier/ProcessorSupplier StateStore connecting2.6399: Extend ProductionExceptionHandler to cover serialization exceptions2.5396: Add Commit/List Offsets Operations to AdminClient2.5394: Require member.id for initial join group request2.2393: Time windowed serde to properly deserialize changelog input topic2.2392: Allow consumers to fetch from closest replica2.4389: Introduce a configurable consumer group size limit2.2386: Standardize on Min/Avg/Max metrics' default value2.2382: MirrorMaker 224.379: Multiple Consumer Group Management2.4.0 380: Detect outdated control requests and bounced brokers using broker generation2.2377: TopicCommand to use AdminClient2.2.0376: Implement AutoClosable on appropriate classes that want to be used in a try-with-resource statement2.2374: Add '--help' option to all available Kafka CLI commands2.2.0 | KIP-373: Allow users to create delegation tokens for other users | 2.7372: Naming Repartition Topics for Joins and Grouping2.1371: Add a configuration to build custom SSL principal name2.2369: Alternative Partitioner to Support "Always Round-Robin" Selection2.4 368: Allow SASL Connections to Periodically Re-Authenticate2.2367 Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)2.2366: Make FunctionConversions deprecated2.1365: Materialized, Serialized, Joined, Consumed and Produced with implicit Serde2.1.0 | KIP-361: Add Consumer Configuration to Disable Auto Topic Creation | 2.3360 Improve reliability of idempotent/transactional producer2.4.0 (partially implemented) / 2.5.359: Verify leader epoch in produce requests2.7.0 (WIP) | KIP-358: Migrate Streams API to Duration instead of long ms times | 2.1357 Add support to list ACLs per principal2.1356 withCachingDisabled() to StoreBuilder2.1.0354: Add a Maximum Log Compaction Lag335321352: Distinguish URPs caused by reassignment2.5.0 351 --under-min-isr option to describe topics command2.3346: Improve LogCleaner behavior on error2.1345: Introduce static membership protocol to reduce consumer rebalances4-342 Add support for custom SASL extensions in OAuthBearer authentication1341: Update Sticky Assignor's User Data Protocol3340: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file1339: Create a new IncrementalAlterConfigs API30 338 Support to exclude the internal topics in kafka-topics.sh command1336: Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer2.1332 Update AclCommand to use AdminClient API1331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde3330: Add retentionPeriod in SessionBytesStoreSupplier1328: Ability to suppress updates for KTables1 (partially implemented; inactive)324: Add method to get metrics() in AdminClient1322: Return new error code for DeleteTopics API when topic deletion disabled.2.1.0 | KIP-321: Update TopologyDescription to better represent Source and Sink Nodes | 2.1.0 |
KIP-320: Allow fetchers to detect and handle log truncation | 2.1.0 (partially implemented). full implementation in 2.4.0 |
KIP-319: Replace segments with segmentInterval in WindowBytesStoreSupplier | 2.1.0 |
KIP-313: Add KStream.flatTransform and KStream.flatTransformValues | 2.2.0 (partially implemented) / 2.3.0 |
KIP-312 Add Overloaded StreamsBuilder Build Method to Accept java.util.Properties | 2.1.0 |
KIP-309: Add toUpperCase support to sasl.kerberos.principal.to.local rule | 2.4.0 |
KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides | 2.1.0 |
KIP-307: Allow to define custom processor names with KStreams DSL | 2.3.0 (partially implemented) / 2.4.0 |
KIP-306: Configuration for Delaying Response to Failed Authentication | 2.1.0 |
KIP-305: Add Connect primitive number converters | 2.0.0 |
KIP-303: Add Dynamic Routing in Streams Sink | 2.0.0 |
KIP-302 - Enable Kafka clients to use all DNS resolved IP addresses | 2.1.0 |
KIP-300: Add Windowed KTable API in StreamsBuilder | 3.0.0 (not implemented; inactive) |
KIP-298: Error Handling in Connect | 2.0.0 |
KIP-297: Externalizing Secrets for Connect Configurations | 2.0.0 |
KIP-295 Add Streams Configuration Allowing for Optional Topology Optimization | 2.0.0 |
KIP-294 - Enable TLS hostname verification by default | 2.0.0 |
KIP-291: Separating controller connections and requests from the data plane | Accepted |
KIP-292: Add transformValues() method to KTable | 2.0.0 |
KIP-290: Support for Prefixed ACLs | 2.0.0 |
KIP-289: Improve the default group id behavior in KafkaConsumer | 2.2.0 |
KIP-285: Connect Rest Extension Plugin | 2.0.0 |
KIP-284: Set default retention ms for Streams repartition topics to Long.MAX_VALUE | 2.0.0 |
KIP-283: Efficient Memory Usage for Down-Conversion | 2.0.0 |
KIP-282: Add the listener name to the authentication context | 2.0.0 |
KIP-281: ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User | 2.0.0 |
KIP-280: Enhanced log compaction | 2.7.0 (WIP) |
KIP-279: Fix log divergence between leader and follower after fast leader fail over | 2.0.0 |
KIP-278 - Add version option to Kafka's commands | 2.0.0 |
KIP-277 - Fine Grained ACL for CreateTopics API | 2.0.0 |
KIP-276 - Add StreamsConfig prefix for different consumers | 2.0.0 |
KIP-274: Kafka Streams Skipped Records Metrics | 2.0.0 |
KIP-272: Add API version tag to broker's RequestsPerSec metric | 2.0.0 |
KIP-270 - A Scala Wrapper Library for Kafka Streams | 2.0.0 |
KIP-268: Simplify Kafka Streams Rebalance Metadata Upgrade | 2.0.0 |
KIP-267: Add Processor Unit Test Support to Kafka Streams Test Utils | 2.0.0 |
KIP-266: Fix consumer indefinite blocking behavior | 2.0.0 |
KIP-265: Make Windowed Serde to public APIs | 2.0.0 |
KIP-261: Add Single Value Fetch in Window Stores | 2.0.0 |
KIP-258: Allow to Store Record Timestamps in RocksDB | 2.3.0 (partially implemented; inactive) |
KIP-257 - Configurable Quota Management | 2.0.0 |
KIP-255: OAuth Authentication via SASL/OAUTHBEARER | 2.0.0 |
KIP-251: Allow timestamp manipulation in Processor API | 2.0.0 |
KIP-249: Add Delegation Token Operations to KafkaAdminClient | 2.0.0 |
KIP-247: Add public test utils for Kafka Streams | 1.1.0 |
KIP-245: Use Properties instead of StreamsConfig in KafkaStreams constructor | 2.0.0 |
KIP-244: Add Record Header support to Kafka Streams Processor API | 2.0.0 |
KIP-243: Make ProducerConfig and ConsumerConfig constructors public | 1.1.0 |
KIP-239 Add queryableStoreName() to GlobalKTable | 1.1.0 |
KIP-238: Expose Kafka cluster ID in Connect REST API | 1.1.0 |
KIP-237: More Controller Health Metrics | 2.0.0 |
KIP-235: Add DNS alias support for secured connection | 2.1.0 |
KIP-233: Simplify StreamsBuilder#addGlobalStore | 1.1.0 |
KIP-231: Improve the Required ACL of ListGroups API | 2.1.0 |
KIP-229: DeleteGroups API | 1.1.0 |
KIP-227 - Introduce Incremental FetchRequests to Increase Partition Scalability | 1.1.0 |
KIP-226 - Dynamic Broker Configuration | 1.1.0 |
KIP-225 - Use tags for consumer “records.lag” metrics | 1.1.0 |
KIP-224: Add configuration parameter `retries` to Streams API | 1.1.0 |
KIP-223 - Add per-topic min lead and per-partition lead metrics to KafkaConsumer | 2.0.0 |
KIP-222 - Add Consumer Group operations to Admin API | 2.0.0 |
KIP-221: Enhance DSL with Connecting Topic Creation and Repartition Hint | 2.6.0 |
KIP-220: Add AdminClient into Kafka Streams' ClientSupplier | 1.1.0 |
KIP-219 - Improve quota communication | 2.0.0 |
KIP-218: Make KafkaFuture.Function java 8 lambda compatible | 1.1.0 |
KIP-216: IQ should throw different exceptions for different errors | 2.7.0 (WIP) |
KIP-215: Add topic regex support for Connect sinks | 1.1.0 |
KIP-214: Add zookeeper.max.in.flight.requests config to the broker | 1.1.0 |
KIP-213 Support non-key joining in KTable | 2.4.0 |
KIP-212: Enforce set of legal characters for connector names | 1.1.0 |
KIP-211: Revise Expiration Semantics of Consumer Group Offsets | 2.1.0 |
KIP-210 - Provide for custom error handling when Kafka Streams fails to produce | 1.1.0 |
KIP-208: Add SSL support to Kafka Connect REST interface | 1.1.0 |
KIP-207: Offsets returned by ListOffsetsResponse should be monotonically increasing even during a partition leader change | 2.2.0 |
KIP-206: Add support for UUID serialization and deserialization | 2.1.0 |
KIP-205: Add all() and range() API to ReadOnlyWindowStore | 1.1.0 |
KIP-204 : Adding records deletion operation to the new Admin Client API | 1.1.0 |
KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule | 1.1.0 |
KIP-202: Move merge() from StreamsBuilder to KStream | 1.0.0 |
KIP-198: Remove ZK dependency from Streams Reset Tool | 1.0.0 |
KIP-197 Connect REST API should include the connector type when describing a connector | 1.0.0 |
KIP-196: Add metrics to Kafka Connect framework | 1.0.0 |
KIP-195: AdminClient.createPartitions | 1.0.0 |
KIP-192 : Provide cleaner semantics when idempotence is enabled | 1.0.0 |
KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern | 1.0.0 |
KIP-190: Handle client-ids consistently between clients and brokers | 1.0.0 |
KIP-189: Improve principal builder interface and add support for SASL | 1.0.0 |
KIP-188 - Add new metrics to support health checks | 1.0.0 |
KIP-187 - Add cumulative count metric for all Kafka rate metrics | 1.0.0 |
KIP-186: Increase offsets retention default to 7 days | 2.0.0 |
KIP-183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient | 2.2.0 |
KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines | 1.0.0 |
KIP-180: Add a broker metric specifying the number of consumer group rebalances in progress | 1.1.0 |
KIP-177: Consumer perf tool should count rebalance time | 1.0.0 |
KIP-176: Remove deprecated new-consumer option for tools | 2.0.0 |
KIP-175: Additional '--describe' views for ConsumerGroupCommand | 1.1.0 |
KIP-174 - Deprecate and remove internal converter configs in WorkerConfig | 2.0.0 |
KIP-173: Add prefix to StreamsConfig to enable setting default internal topic configs | 1.0.0 |
KIP-171 - Extend Consumer Group Reset Offset for Stream Application | 1.1.0 |
KIP-168: Add GlobalTopicCount and GlobalPartitionCount metric per cluster | 1.0.0 |
KIP-167: Add interface for the state store restoration process | 1.0.0 |
KIP-164 - Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics | 1.0.0 |
KIP-163: Lower the Minimum Required ACL Permission of OffsetFetch | 1.0.0 |
KIP-162: Enable topic deletion by default | 1.0.0 |
KIP-161: streams deserialization exception handlers | 1.0.0 |
KIP-160: Augment KStream.print(), KStream.writeAsText() to allow users pass in extra parameters in the printed string | 1.0.0 |
KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics | 2.6.0 |
KIP-157 - Add consumer config options to streams reset tool | 1.0.0 |
KIP-156 Add option "dry run" to Streams application reset tool | 0.11.0.0 |
KIP-155 - Add range scan for windowed state stores | 0.11.0.0 |
KIP-154 Add Kafka Connect configuration properties for creating internal topics | 0.11.0.0 |
KIP-153: Include only client traffic in BytesOutPerSec metric | 0.11.0.0 |
KIP-152 - Improve diagnostics for SASL authentication failures | 1.0.0 |
KIP-151 Expose Connector type in REST API | 0.11.0.0 |
KIP-150 - Kafka-Streams Cogroup | 2.5.0 |
KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner | 1.1.0 (partially implemented; inactive) |
KIP-146 - Classloading Isolation in Connect | 0.11.0.0 |
KIP-145 - Expose Record Headers in Kafka Connect | 1.1.0 |
KIP-144: Exponential backoff for broker reconnect attempts | 0.11.0.0 |
KIP-143: Controller Health Metrics | 0.11.0.0 |
KIP-140: Add administrative RPCs for adding, deleting, and listing ACLs | 0.11.0.0 |
KIP-138: Change punctuate semantics | 1.0.0 |
KIP-137: Enhance TopicCommand --describe to show topics marked for deletion | 0.11.0.0 |
KIP-136: Add Listener name to SelectorMetrics tags | 0.11.0.0 |
KIP-134: Delay initial consumer group rebalance | 0.11.0.0 |
KIP-133: Describe and Alter Configs Admin APIs | 0.11.0.0 |
KIP-131 - Add access to OffsetStorageReader from SourceConnector | 2.6.0 |
KIP-130: Expose states of active tasks to KafkaStreams public API | 1.0.0 |
KIP-129: Streams Exactly-Once Semantics | 0.11.0.0 |
KIP-128: Add ByteArrayConverter for Kafka Connect | 0.11.0.0 |
KIP-126 - Allow KafkaProducer to split and resend oversized batches. | 0.11.0.0 |
KIP-124 - Request rate quotas | 0.11.0.0 |
KIP-123: Allow per stream/table timestamp extractor | 0.11.0.0 |
KIP-122: Add Reset Consumer Group Offsets tooling | 0.11.0.0 |
KIP-121: Add KStream peek method | 0.11.0.0 |
KIP-120: Cleanup Kafka Streams builder API | 1.0.0 |
KIP-119: Drop Support for Scala 2.10 in Kafka 0.11 | 0.11.0.0 |
KIP-118: Drop Support for Java 7 | 2.0.0 |
KIP-117: Add a public AdminClient API for Kafka admin operations | 0.11.0.0 |
KIP-115: Enforce offsets.topic.replication.factor upon __consumer_offsets auto topic creation | 0.11.0.0 |
KIP-114: KTable state stores and improved semantics | 0.11.0.0 |
KIP-113: Support replicas movement between log directories | 1.1.0 |
KIP-112: Handle disk failure for JBOD | 1.0.0 |
KIP-110: Add Codec for ZStandard Compression | 2.1.0 |
KIP-109: Old Consumer Deprecation | 0.11.0.0 |
KIP-108: Create Topic Policy | 0.10.2.0 |
KIP-107: Add deleteRecordsBefore() API in AdminClient | 0.11.0.0 |
KIP-106 - Change Default unclean.leader.election.enabled from True to False | 0.11.0.0 |
KIP-105: Addition of Record Level for Sensors | 0.10.2.0 |
KIP-104: Granular Sensors for Streams | 0.10.2.0 |
KIP-103: Separation of Internal and External traffic | 0.10.2.0 |
KIP-102 - Add close with timeout for consumers | 0.10.2.0 |
KIP-101 - Alter Replication Protocol to use Leader Epoch rather than High Watermark for Truncation | 0.11.0.0 |
KIP-100 - Relax Type constraints in Kafka Streams API | 0.10.2.0 |
KIP-99: Add Global Tables to Kafka Streams | 0.10.2.0 |
KIP-98 - Exactly Once Delivery and Transactional Messaging | 0.11.0.0 |
KIP-97: Improved Kafka Client RPC Compatibility Policy | 0.10.2.0 |
KIP-96 - Add per partition metrics for in-sync and assigned replica count | 0.10.2.0 |
KIP-94 Session Windows | 0.10.2.0 |
KIP-93: Improve invalid timestamp handling in Kafka Streams | 0.10.2.0 |
KIP-92 - Add per partition lag metrics to KafkaConsumer | 0.10.2.0 |
KIP-91 Provide Intuitive User Timeouts in The Producer | 2.1.0 |
KIP-90 - Remove zkClient dependency from Streams | 0.10.2.0 |
KIP-89: Allow sink connectors to decouple flush and offset commit | 0.10.2.0 |
KIP-88: OffsetFetch Protocol Update | 0.10.2.0 |
KIP-86: Configurable SASL callback handlers | 2.0.0 |
KIP-85: Dynamic JAAS configuration for Kafka clients | 0.10.2.0 |
KIP-84: Support SASL SCRAM mechanisms | 0.10.2.0 |
KIP-82 - Add Record Headers | 0.11.0.0 |
KIP-81: Bound Fetch memory usage in the consumer | 2.7.0 (WIP) |
KIP-79 - ListOffsetRequest/ListOffsetResponse v1 and add timestamp search methods to the new consumer | 0.10.1.0 |
KIP-78: Cluster Id | 0.10.1.0 |
KIP-77: Improve Kafka Streams Join Semantics | 0.10.2.0 |
KIP-75 - Add per-connector Converters | 0.10.1.0 |
KIP-74: Add Fetch Response Size Limit in Bytes | 0.10.1.0 |
KIP-73: Replication Quotas | 0.10.1.0 |
KIP-72: Allow putting a bound on memory consumed by Incoming request | 1.0.0 |
KIP-71: Enable log compaction and deletion to co-exist | 0.10.1.0 |
KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change | 0.10.1.0 |
KIP-67: Queryable state for Kafka Streams | 0.10.1.0 |
KIP-66: Single Message Transforms for Kafka Connect | 0.10.2.0 / 0.11.0.0 |
KIP-65: Expose timestamps to Connect | 0.10.1.0 |
KIP-63: Unify store and downstream caching in streams | 0.10.1.0 |
KIP-62: Allow consumer to send heartbeats from a background thread | 0.10.1.0 |
KIP-60 - Make Java client classloading more flexible | 0.10.1.0 |
KIP-58 - Make Log Compaction Point Configurable | 0.10.1.0 |
KIP-57 - Interoperable LZ4 Framing | 0.10.0.0 |
KIP-56: Allow cross origin HTTP requests on all HTTP methods | 0.10.0.0 |
KIP-55: Secure Quotas for Authenticated Users | 0.10.1.0 |
KIP-54: Sticky Partition Assignment Strategy | 0.11.0.0 |
KIP-52: Connector Control APIs | 0.10.0.0 |
KIP-51 - List Connectors REST API | 0.10.0.0 |
KIP-48 Delegation token support for Kafka | 1.1.0 |
KIP-45 - Standardize all client sequence interaction on j.u.Collection. | 0.10.0.0 |
KIP-43: Kafka SASL enhancements | 0.10.0.0 |
KIP-42: Add Producer and Consumer Interceptors | 0.10.0.0 |
KIP-41: Consumer Max Records | 0.10.0.0 |
KIP-40: ListGroups and DescribeGroup | 0.9.0.0 |
KIP-38: ZooKeeper Authentication | 0.9.0.0 |
KIP-36 - Rack aware replica assignment | 0.10.0.0 |
KIP-35 - Retrieving protocol version | 0.10.0.0 |
KIP-33 - Add a time based log index | 0.10.1.0 |
KIP-32 - Add timestamps to Kafka message | 0.10.0.0 |
KIP-31 - Move to relative offsets in compressed message sets | 0.10.0.0 |
KIP-28 - Add a processor client | 0.10.0.0 |
KIP-26 - Add Kafka Connect framework for data import/export | 0.9.0.0 |
KIP-25 - System test improvements | 0.9.0.0 |
KIP-22 - Expose a Partitioner interface in the new producer | 0.9.0.0 |
KIP-21 - Dynamic Configuration | 0.9.0.0 (WIP) |
KIP-20 Enable log preallocate to improve consume performance under windows and some old Linux file system | 0.9.0.0 |
KIP-19 - Add a request timeout to NetworkClient | 0.9.0.0 |
KIP-16 - Automated Replica Lag Tuning | 0.9.0.0 |
KIP-15 - Add a close method with a timeout in the producer | 0.9.0.0 |
KIP-13 - Quota Design | 0.9.0.0 |
KIP-12 - Kafka Sasl/Kerberos and SSL implementation | 0.9.0.0 |
KIP-11 - Kafka Authorizer design | 0.9.0.0 |
KIP-8 - Add a flush method to the producer API | 0.9.0.0 |
KIP-4 - Metadata Protocol Changes | 0.10.0.0 |
KIP-4 - Command line and centralized administrative operations | 0.9.0.0, 0.10.0.0, 0.10.1.0 |
KIP-3 - Mirror Maker Enhancement | 0.9.0.0 |
KIP-2 - Refactor brokers to allow listening on multiple ports and IPs | 0.9.0.0 |
KIP-1 - Remove support of request.required.acks | 0.9.0.0 |
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...