Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Move KIP-183 to postponed KIP table

...

  • KIP Freeze: January 23, 2018 (a KIP must be accepted by this date in order to be considered for this release)
  • Feature Freeze: January 30, 2018 (major features merged & working on stabilization, minor features have PR, release branch cut; anything not in this state will be automatically moved to the next release in JIRA)
  • Code Freeze: February 13, 2018 (first RC created now)
  • Release: February 27March 28, 2018 (Tentatively)


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.

...

  • Significant Controller improvements (much faster and session expiration edge cases fixed)
  • Data balancing across log directories (JBOD)
  • More efficient replication when the number of partitions is large
  • Dynamic Broker Configs
  • Delegation tokens (KIP-48)
  • Kafka Streams API improvements (KIP-205 / 210 / 220 / 224 / 239)

...

MultipleIsmael Juma Juma guozhang WangEwen Cheslack-Postava
KIPJIRAComponentCommitter
KIP-86: Configurable SASL callback handlers
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-4292
BrokerRajini SivaramKIP-91 Provide Intuitive User Timeouts in The Producer Client?
KIP-145 - Expose Record Headers in Kafka Connect
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5142
ConnectEwen Cheslack-Postava
KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-4218

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-4726

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5764

Streamsguozhang Wang

KIP-171 - Extend Consumer Group Reset Offset for Stream Application

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5520
Streamsguozhang Wang
KIP-174 - Deprecate and remove internal converter configs in WorkerConfig
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5540
ConnectEwen Cheslack-Postava
KIP-183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5692
Ismael Juma Juma
KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule 
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5764
SecurityJason Gustafson
KIP-204 : Adding records deletion operation to the new Admin Client API
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5925
Admin Clientguozhang Wang
KIP-205: Add all() and range() API to ReadOnlyWindowStore
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-4499
Streamsguozhang Wang
KIP-208: Add SSL support to Kafka Connect REST interface
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-4029
ConnectEwen Cheslack-Postava
KIP-210 - Provide for custom error handling when Kafka Streams fails to produce
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6086
StreamsDamian Guy
KIP-212: Enforce set of legal characters for connector names
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-4930
ConnectEwen Cheslack-Postava
KIP-214: Add zookeeper.max.in.flight.requests config to the broker
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5894
BrokerJiangjie Qin
KIP-215: Add topic regex support for Connect sinks
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-3073
ConnectEwen Cheslack-Postava
KIP-218: Make KafkaFuture.Function java 8 lambda compatible
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6018
ClientEwen Cheslack-Postava
KIP-220: Add AdminClient into Kafka Streams' ClientSupplier
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6170
Streamsguozhang Wang
KIP-223 - Add per-topic min lead and per-partition lead metrics to KafkaConsumer
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6184
ClientJun Rao

KIP-224: Add configuration parameter `retries` to Streams API

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6122
Streamsguozhang Wang
KIP-225 - Use tags for consumer “records.lag” metrics
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5890
ClientJiangjie Qin
KIP-226 - Dynamic Broker Configuration
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6240
BrokerRajini Sivaram
KIP-227 - Introduce Incremental FetchRequests to Increase Partition Scalability
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6254
BrokerJun Rao
KIP-229: DeleteGroups API
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6275
MultipleJason Gustafson

KIP-233: Simplify StreamsBuilder#addGlobalStore

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6138
StreamsMatthias Sax
KIP-237: More Controller Health Metrics
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-3473
BrokerIsmael Juma Juma
KIP-238: Expose Kafka cluster ID in Connect REST API
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6311
ConnectJason Gustafson
KIP-239 Add queryableStoreName() to GlobalKTable
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6265
Streamsguozhang Wang
KIP-243: Make ProducerConfig and ConsumerConfig constructors public
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6382
ClientMatthias Sax

KIP-

242: Mask password in Kafka Connect Rest API response

247: Add public test utils for Kafka Streams

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5117
Connect
3625
Streamsguozhang Wang

Postponed to subsequent release

243: Make ProducerConfig and ConsumerConfig constructors public6382Matthias Sax
KIPJIRAComponentCommitter
KIP-48: Delegation token support for Kafka
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-
Client
4541
Broker 
KIP-91 Provide Intuitive User Timeouts in The Producer
Clients

KIP-245: Use Properties instead of StreamsConfig in KafkaStreams constructor149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner

(only partially implemented in 1.1.0)

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-

6386
Streamsguozhang Wang

4218

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-4726
KIP-247: Add public test utils for Kafka Streams

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-

3625

5764

Streamsguozhang Wang

Postponed to subsequent release

Committer
?
KIP-183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient
Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5692
MultipleIsmael Juma JumaKIPJIRAComponent
KIP-150 - Kafka-Streams Cogroup
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6049
Streams ?
KIP-245: Use Properties instead of StreamsConfig in KafkaStreams constructor
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6386
Streams?