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- |
662: Throw Exception when Source Topics of a Streams App are Deleted2.7654: Aborted transaction with non-flushed data should throw a non-fatal exceptionWIP | KIP-651 - Support PEM format for SSL certificates and private key | 2.7.0 (WIP) |
KIP-648 Renaming getter method for Interactive Queries | 2.7632: Add DirectoryConfigProvider2.7629: Use racially neutral terms in our codebaseWIP627 Trogdor-specific JMX Metrics for Tasks and Agents2.7.0 (WIP)626: Rename StreamsConfig config variable name2.7623 "internal-topics" option to streams application reset tool2 (WIP)621: Deprecate and replace DescribeLogDirsResult.all() and .values()2.7.0 (WIP) | KIP-620 Deprecate ConsumerConfig#addDeserializerToConfig and ProducerConfig#addSerializerToConfig | 2.7.0 (WIP) |
KIP-617: Allow Kafka Streams State Stores to be iterated backwards | 2.7.0 (WIP) |
KIP-616: Rename implicit Serdes instances in kafka-streams-scala | 2.7.0 (WIP) |
KIP-613: Add end-to-end latency metrics to Streams | 2.6.0 (INFO node-level metrics), remainder 2.7.0 (TRACE store-level metrics) |
KIP-612: Ability to Limit Connection Creation Rate on Brokers | 2.7.0 (WIP) |
KIP-610: Error Reporting in Sink Connectors | 2.6.0 |
KIP-608: Expose Kafka Metrics in Authorizer | 2.7.0 (WIP) |
KIP-607: Add Metrics to Kafka Streams to Report Properties of RocksDB | 2606: Add Metadata Context to MetricsReporter2.6.0605: Expand Connect Worker Internal Topic Settings2.6604: Remove ZooKeeper Flags from the Administrative Toolsone part in 2.6.0, most parts scheduled for 3602: Change default value for client.dns.lookup2.6.0 | KIP-601: Configurable socket connection timeout | 2.7.0 |
KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations | 2WIP2.7KIP-597: MirrorMaker2 internal topics Formatters | WIP594: Expose output topic names from TopologyTestDriver2.6590: Redirect Zookeeper Mutation Protocols to The Controller2.7.0 (WIP) | KIP-589 Add API to update Replica state in Controller | 2 (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)577: Allow HTTP Response Headers to be Configured for Kafka Connect2.6.0 | KIP-574: CLI Dynamic Configuration with file input | 2.6.0 |
KIP-573: Enable TLSv1.3 by default | 2572: Improve timeouts and retries 2WIPKIP-571: Add option to force remove members in StreamsResetter | 23.6.0 (partially implemented) |
KIP- |
570 leader epoch in StopReplicaRequest2569: DescribeConfigsResponse - Update the schema to include additional metadata information of the field2.6568: Explicit rebalance triggering on the Consumer2562: 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 Connect2557 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.2.5551: Expose disk read and write metrics2.6546: 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.5.0528: Deprecate PartitionGrouper configuration and interface2527: Add VoidSerde to Serdes2KIP-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.6.0 | KIP-518: Allow listing consumer groups per state | 2.6517: Add consumer metrics to observe user poll behavior2.4.0515: Enable ZK client to use the new TLS supported authentication2.5514:Add a bounded flush() API to Kafka Producer2.5511: Collect and Expose Client's Name and Version in the Brokers2.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 | 2484 metrics for group and transaction metadata loading duration2.4.0 482: The Kafka Protocol should Support Optional Tagged Fields2.4.0 481: SerDe Improvements for Connect Decimal type in JSON2.4480: Sticky Partitioner2.4479 StreamJoined config object to Join2.4478 - Strongly typed Processor APIWIP | KIP-476: Add Java AdminClient Interface | 2475: 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.5.0 |
KIP-466: Add support for List<T> serialization and deserialization | 2.7.0 (WIP) |
KIP-465: Add Consolidated Connector Endpoint to Connect REST API | 2.3.0 |
KIP-464: Defaults for AdminClient#createTopic | 2.4.0 |
KIP-462: Use local thread id for KStreams | 2.3.0 |
KIP-461: Improve Replica Fetcher behavior at handling partition failure | 2460: Admin Leader Election RPC2.4458: 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 DSL2.7449 connector contexts to log messages in Connect workers 2.3447: Producer scalability for exactly once semantics2.5.0 (broker, consumer, producer changes implemented) / 2.6.446: Add changelog topic configuration to KTable suppress2445: In-memory Session Store2444: Augment metrics for Kafka Streams2.4.0 (partially implemented) / 2.5.0 (partially implemented) / 2.443: Return to default segment.ms and segment.index.bytes in Streams repartition topics2.3442 Return to default max poll interval in Streams2.3.441: Smooth Scaling Out for Kafka Streams2.6440: Extend Connect Converter to support headers2437: Custom replacement for MaskField SMT2.6436 a metric indicating start time2.3434: Add Replica Fetcher and Log Cleaner Count Metrics2.4430 - Return Authorized Operations in Describe Responses2429: Kafka Consumer Incremental Rebalance Protocol2.4428: 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.3.0 | KIP-421: Support resolving externalized secrets in AbstractConfig | 2.3.0 |
KIP-420: Add Single Value Fetch in Session Stores | 2418: A method-chaining way to branch KStream2.7417: Allow JmxTool to connect to a secured RMI port2.3415: Incremental Cooperative Rebalancing in Kafka Connect2.3414: Expose Embedded ClientIds in Kafka Streams2.2412: Extend Admin API to support dynamic application log levels2.4.0 411: Make default Kafka Connect worker task client IDs distinct2.3.0 | KIP-402: Improve fairness in SocketServer processors | 2.2.0 (partially implemented) / 2.3.0 |
KIP-401: TransformerSupplier/ProcessorSupplier StateStore connecting | 2.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 | KIP-380: Detect outdated control requests and bounced brokers using broker generation | 2.2377: TopicCommand to use AdminClient2.2376: 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.2373: Allow users to create delegation tokens for other users2.7372: Naming Repartition Topics for Joins and Grouping2.1.0 | KIP-371: Add a configuration to build custom SSL principal name | 2.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.2.0 | KIP-366: Make FunctionConversions deprecated | 2.1365: Materialized, Serialized, Joined, Consumed and Produced with implicit Serde2.1KIP361: Add Consumer Configuration to Disable Auto Topic Creation2.3360: Improve reliability of idempotent/transactional producer2.4.0 (partially implemented) / 2359: Verify leader epoch in produce requests2.7.0 (WIP)358: Migrate Streams API to Duration instead of long ms times2.1357: Add support to list ACLs per principal2.1356: Add withCachingDisabled() to StoreBuilder2.1.354 a Maximum Log Compaction Lag3353: Improve Kafka Streams Timestamp Synchronization2.1352: Distinguish URPs caused by reassignment2.5.0 351: Add --under-min-isr option to describe topics command3346 Improve LogCleaner behavior on error2.1345: Introduce static membership protocol to reduce consumer rebalances2.4.0342 Add support for custom SASL extensions in OAuthBearer authentication2341: Update Sticky Assignor's User Data Protocol2.3340: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file1-339: Create a new IncrementalAlterConfigs API30 338 Support to exclude the internal topics in kafka-topics.sh command1336: Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer1332: Update AclCommand to use AdminClient API1331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde3330 retentionPeriod in SessionBytesStoreSupplier2.1328 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.1321: Update TopologyDescription to better represent Source and Sink Nodes2.1.0 | KIP-320: Allow fetchers to detect and handle log truncation | 2.1.0 (partially implemented). full implementation in 2.4319 Replace segments with segmentInterval in WindowBytesStoreSupplier1313: Add KStream.flatTransform and KStream.flatTransformValues 2partially implemented)/ 2.3312 Add Overloaded StreamsBuilder Build Method to Accept java.util.Properties1309: Add toUpperCase support to sasl.kerberos.principal.to.local rule2.4308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides2.1.307: Allow to define custom processor names with KStreams DSL2.3.0 (partially implemented) / 2.4306: Configuration for Delaying Response to Failed Authentication1305: Add Connect primitive number converters0303: Add Dynamic Routing in Streams Sink2302 - Enable Kafka clients to use all DNS resolved IP addresses2.1.0 | KIP-300: Add Windowed KTable API in StreamsBuilder (not implemented; inactive)298: Error Handling in Connect2.0.0297: Externalizing Secrets for Connect Configurations0295 Add Streams Configuration Allowing for Optional Topology Optimization2294 - Enable TLS hostname verification by default2291: Separating controller connections and requests from the data planeAccepted | KIP-292: Add transformValues() method to KTable | 2.0290: Support for Prefixed ACLs0289: Improve the default group id behavior in KafkaConsumer2.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.0283: Efficient Memory Usage for Down-Conversion0282 the listener name to the authentication context0281: ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User280: Enhanced log compaction (WIP)279: Fix log divergence between leader and follower after fast leader fail over0278 - Add version option to Kafka's commands0277 - Fine Grained ACL for CreateTopics API0276 - Add StreamsConfig prefix for different consumers0274: Kafka Streams Skipped Records Metrics2.0272: Add API version tag to broker's RequestsPerSec metric0270 - A Scala Wrapper Library for Kafka Streams0268: Simplify Kafka Streams Rebalance Metadata Upgrade0267: Add Processor Unit Test Support to Kafka Streams Test Utils0266: Fix consumer indefinite blocking behavior0265: Make Windowed Serde to public APIs2.0.0261: Add Single Value Fetch in Window Stores0258: Allow to Store Record Timestamps in RocksDB3partially implemented; inactive257 - Configurable Quota Management0255: OAuth Authentication via SASL/OAUTHBEARER0251: Allow timestamp manipulation in Processor API0249: Add Delegation Token Operations to KafkaAdminClient0247: Add public test utils for Kafka Streams1.1245: Use Properties instead of StreamsConfig in KafkaStreams constructor2.0244: Add Record Header support to Kafka Streams Processor API0243: Make ProducerConfig and ConsumerConfig constructors public1.1239 Add queryableStoreName() to GlobalKTable1.1238: Expose Kafka cluster ID in Connect REST API1.1.0 | KIP-237: More Controller Health Metrics | 2.0.0 |
KIP-235: Add DNS alias support for secured connection | 2.1233: Simplify StreamsBuilder#addGlobalStore1.1231 Improve the Required ACL of ListGroups API1229: DeleteGroups API1.1227 - Introduce Incremental FetchRequests to Increase Partition Scalability1.1226 - Dynamic Broker Configuration1.1225 - Use tags for consumer “records.lag” metrics1.1.0 | KIP-224: Add configuration parameter `retries` to Streams API | 1.1223 - per-topic min lead and per-partition lead metrics to KafkaConsumer0222 - Add Consumer Group operations to Admin API0221: Enhance DSL with Connecting Topic Creation and Repartition Hint220 AdminClient into Kafka Streams' ClientSupplier1.1.0 | KIP-219 - Improve quota communication | 2.0.0 |
KIP-218: Make KafkaFuture.Function java 8 lambda compatible | 1.1216: IQ should throw different exceptions for different errors7 (WIP)215: Add topic regex support for Connect sinks1.1214: Add zookeeperin.flight.requests config to 11213 Support non-key joining in KTable4212: Enforce set of legal characters for connector names1.1211: Revise Expiration Semantics of Consumer Group Offsets1210 - Provide for custom error handling when Kafka Streams fails to produce1208 SSL support to Kafka Connect REST interface1.1207: Offsets returned by ListOffsetsResponse should be monotonically increasing even during a partition leader change2.2.0 | KIP-206: Add support for UUID serialization and deserialization | 2.1.0 |
KIP-205: Add all() and range() API to ReadOnlyWindowStore | 1.1204 : Adding records deletion operation to the new Admin Client API1.1203 toLowerCase support to sasl.kerberos.principal.to.local rule 1.1202: Move merge() from StreamsBuilder to KStream1.0198: Remove ZK dependency from Streams Reset Tool1.0.0 | KIP-197 Connect REST API should include the connector type when describing a connector | 1.0196 metrics to Kafka Connect framework1.0195: AdminClient.createPartitions1.0192 : Provide cleaner semantics when idempotence is enabled1.0191: KafkaConsumer.subscribe() overload that takes just Pattern1.0190: Handle client-ids consistently between clients and brokers1.0189: Improve principal builder interface and add support for SASL1.0.0 | KIP-188 - Add new metrics to support health checks | 1.0187 - Add cumulative count metric for all Kafka rate metrics1.0186: Increase offsets retention default to 7 days183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient2-182: Reduce Streams DSL overloads and allow easier use of custom storage engines1.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 SourceConnector130: Expose states of active tasks to KafkaStreams public API1.0129 Streams Exactly-Once Semantics0.11.0.0 | KIP-128: Add ByteArrayConverter for Kafka Connect | 0.11.0126 - Allow KafkaProducer to split and resend oversized batches.0.11.0.0 | KIP-124 - Request rate quotas | 0.11.0123: Allow per stream/table timestamp extractor0.11.0122: Add Reset Consumer Group Offsets tooling0.11.0121: Add KStream peek method0.11.0120: Cleanup Kafka Streams builder API1.0119: Drop Support for Scala 2.10 in Kafka 0.110.11.0.0 | KIP-118: Drop Support for Java 7 | 2.0-117: Add a public AdminClient API for Kafka admin operations0.11.0.0 | KIP-115: Enforce offsets.topic.replication.factor upon __consumer_offsets auto topic creation | 0.11.0114: KTable state stores and improved semantics0.11.0113: Support replicas movement between log directories1.1112: Handle disk failure for JBOD1.0110 Codec for ZStandard Compression1109: Old Consumer Deprecation0.11.0108: Create Topic Policy0.10.2.107: Add deleteRecordsBefore() API in AdminClient0.11.0.0 | KIP-106 - Change Default unclean.leader.election.enabled from True to False | 0.11.0105: Addition of Record Level for Sensors0.10.2.0104: Granular Sensors for Streams 0.10.2103: Separation of Internal and External traffic0.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.1088: OffsetFetch Protocol Update0.10.86: Configurable SASL callback handlers085: Dynamic JAAS configuration for Kafka clients0.10.84: Support SASL SCRAM mechanisms0.10.2.0 | KIP-82 - Add Record Headers | 0.11.081: Bound Fetch memory usage in the consumer7 (WIP)79 - ListOffsetRequest/ListOffsetResponse v1 and add timestamp search methods to the new consumer0.10.1-78: Cluster Id0.10.177: Improve Kafka Streams Join Semantics0.1075 - Add per-connector Converters0.10.74: Add Fetch Response Size Limit in Bytes0.10KIP73: Replication Quotas0.10.1.72: Allow putting a bound on memory consumed by Incoming request 1.071: Enable log compaction and deletion to co-exist0.10.1.0 | KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change | 0.1067: Queryable state for Kafka Streams0.1066: Single Message Transforms for Kafka Connect0.10.2.0 / 0.11.065: Expose timestamps to Connect0.10.1.63: Unify store and downstream caching in streams0.10.62: Allow consumer to send heartbeats from a background thread0.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.54 Sticky Partition Assignment Strategy0.11.0.052: Connector Control APIs0.10.051 - List Connectors REST 0100.048 Delegation token support for Kafka145 - 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.041: Consumer Max Records0.10.040: ListGroups and DescribeGroup0.9.0.038: ZooKeeper Authentication0.9.036 - Rack aware replica assignment0.10.035 - Retrieving protocol version0.10.033 - Add a time based log index0.10.132 - Add timestamps to Kafka message0.10.0.0 | KIP-31 - Move to relative offsets in compressed message sets | 0.10.028 - Add a processor client0.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.919 - Add a request timeout to NetworkClient0.9.16 - Automated Replica Lag Tuning0.9.015 - Add a close method with a timeout in the producer0.9.13 - Quota Design0.912 - Kafka Sasl/Kerberos and SSL implementation0.911 - Kafka Authorizer design0.9.08 - Add a flush method to the producer API0.94 - Metadata Protocol Changes0.104 - Command line and centralized administrative operations0.9.0.0, 0.10.0.0, 0.10.1.0 | KIP-3 - Mirror Maker Enhancement | 0.92 - Refactor brokers to allow listening on multiple ports and IPs0.9.1 - Remove support of request.required.acks0.9.0.0 | ...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...
...