We will bump this release version  to 1.0.0, and also starting in this release we will have a slight difference in the version numbers such that:

  1. We will use three digits instead of four for the release versions:
  2. The first digit would indicate the major revision (starting at 1), and second indicating minor revision, and the last one number indicating the bug-fix revision; when preparing RCs of the release we will still suffix it after the release version number. I.e. major.minor.bug-fix[-rc_number]

Release Dates


These dates are goals and subject to change, but we expect to stay on the Time Based Release Plan unless unexpected critical issues come up. While the target release date is fixed at ~2w after code freeze, RCs will roll out as needed until the release vote passes.

The release manager is Guozhang Wang.

Release Features

This is a list of key features/improvements/bugfixes that we can include with release notes (WIP):

How to Contribute

Before code freeze:

After code freeze:

Open Issues

Also feel free to refer to this release page for more details of the included tickets.

 

Planned KIP Content

Note: The planned content is not binding - final content will be based the features committed by branch-cutting date. See Kafka Improvement Proposals for the full list of KIPs.

 KIPJIRAComponentCommitter
1KIP-72: Allow putting a bound on memory consumed by Incoming request NetworkJun Rao
2KIP-112: Handle disk failure for JBODBroker Jun Rao
3KIP-113: Support replicas movement between log directories (part 1)

Broker

 Jun Rao

Jiangjie Qin

4KIP-120: Cleanup Kafka Streams builder APIStreamsguozhang Wang
5KIP 130: Expose states of active tasks to KafkaStreams public APIStreamsguozhang Wang
6KIP-138: Change punctuate semanticsStreamsDamian Guy
7KIP-152 - Improve diagnostics for SASL authentication failuresSecurity

Jun Rao (broker)

Rajini Sivaram (client)

8

KIP 157 - Add consumer config options to streams reset tool

StreamsDamian Guy
9KIP-160: Augment KStream.print(), KStream.writeAsText()StreamsDamian Guy
10KIP-161: streams deserialization exception handlersStreamsDamian Guy
11KIP-162: Enable topic deletion by defaultAdminGwen Shapira
12KIP-163: Lower the Minimum Required ACL Permission of OffsetFetchSecurityEwen Cheslack-Postava
13KIP-164- Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metricsBrokerEwen Cheslack-Postava
14KIP-167: Add interface for the state store restoration processStreamsguozhang Wang
15KIP-168: Add GlobalTopicCount and GlobalPartitionCount metric per clusterBrokerJason Gustafson
16KIP-173: Add prefix to StreamsConfig to enable setting default internal topic configsStreamsDamian Guy
17KIP-177: Consumer perf tool should count rebalance timeToolingJason Gustafson
18KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage enginesStreamsguozhang Wang
19KIP-187 - Add cumulative count metric for all Kafka rate metricsMetricsIsmael Juma Juma
20KIP-188 - Add new metrics to support health checksMetricsIsmael Juma Juma
21KIP-189: Improve principal builder interface and add support for SASLBrokerRajini Sivaram
22KIP-190: Handle client-ids consistently between clients and brokersBrokerRajini Sivaram
23KIP-191: KafkaConsumer.subscribe() overload that takes just PatternConsumerJason Gustafson
24KIP-192 : Provide cleaner semantics when idempotence is enabledProducer/BrokerJason Gustafson
25KIP-195: AdminClient.createPartitionsAdminIsmael Juma Juma
26KIP-196: Add metrics to Kafka Connect frameworkConnectEwen Cheslack-Postava
27KIP-197 Connect REST API should include the connector type when describing a connectorConnectEwen Cheslack-Postava
28KIP-198: Remove ZK dependency from Streams Reset ToolToolingguozhang Wang
29KIP-202 Move merge() from StreamsBuilder to KStreamStreamsGuozhang Wang

Postponed to subsequent release

 KIPJIRAComponentCommitter
1KIP-48 Delegation token support for KafkaSecurity ?
2KIP-81: Bound Fetch memory usage in the consumerConsumerJason Gustafson
3KIP-91 Provide Intuitive User Timeouts in The ProducerProducer

Jiangjie Qin

4KIP-113: Support replicas movement between log directories (part 2)BrokerJun Rao
5KIP-118: Drop Support for Java 7Buildguozhang Wang
6KIP-150 - Kafka-Streams CogroupStreamsguozhang Wang
7KIP-180: Add a broker metric specifying the number of consumer group rebalances in progressBrokerJason Gustafson
8KIP-183 - Change PreferredReplicaLeaderElectionCommand to use AdminClientTools/BrokerIsmael Juma Juma