Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Strike through release date

...

  • KIP Freeze: Jan 22, 2020 (a KIP must be accepted by this date in order to be considered for this release)
  • Feature Freeze: Jan 29, 2020 (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: Feb 12, 2020
  • Release: Feb 26, 2020  TBD


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 David Arthur.

...

Planned KIPs

...

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6049

Streams

KIP-352: Distinguish URPs caused by reassignment

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8834
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9059
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8835

Core

KIP-360: Improve reliability of idempotent/transactional producer

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8710

Core/Clients
KIP-396: Add Reset/List Offsets Operations to AdminClient

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7689

Clients
KIP-447: Producer scalability for exactly once semantics (partial)

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8587

Streams
KIP-455: Create an Administrative API for Replica Reassignment

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8345

Core
KIP-511: Collect and Expose Client's Name and Version in the Brokers (new metrics)

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8855

Core/Clients
KIP-515: Enable ZK client to use the new TLS supported authentication

Jira
server

...

ASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8843

Core
KIP-523: Add KStream#toTable to the Streams DSL

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7658

Streams
KIP-524: Allow users to choose config source when describing configs

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9040

Core
KIP-526: Reduce Producer Metadata Lookups for Large Number of Topics

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8904

Clients
KIP-527: Add VoidSerde to Serdes

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8455

Streams
KIP-530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8953

Streams
KIP-531: Drop support for Scala 2.11 in Kafka 2.5

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9324

Core
KIP-535: Allow state stores to serve stale reads during rebalance

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6144

Streams
KIP-537: Increase default zookeeper session timeout

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9102

Core
KIP-538: Add a metric tracking the number of open connections with a given SSL cipher type

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9091

Core
KIP-541: Create a fetch.max.bytes configuration for the broker

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9101

Core
KIP-543: Expand ConfigCommand's non-ZK functionality

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9082

Core
KIP-553: Disable all SSL protocols except TLSV1.2 by default.

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9460

Core
KIP-555: Deprecate Direct Zookeeper access in Kafka Administrative Tools (partial in 2.5)

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9397

Core
KIP-558: Track the set of actively used topics by connectors in Kafka Connect

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9422

Connect
KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9437

Core
KIP-562: Allow fetching a key from a single partition rather than iterating over all the stores on an instance

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9445

Streams


Postponed KIPs

KIPJIRAComponent
KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5295

Connect
KIP-216: IQ should throw different exceptions for different errors

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5876

Streams

KIP-280: Enhanced log compaction

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7061

Core
KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7499

Streams
KIP-401: TransformerSupplier/ProcessorSupplier StateStore connecting

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7523

Streams
KIP-444: Augment metrics for Kafka Streams (some parts in 2.4, some TBD)

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6819

Streams
KIP-467: Augment ProduceResponse error messaging for specific culprit records

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8729

Core/Clients
KIP-514: Add a bounded flush() API to Kafka Producer

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7711

Clients
KIP-544: Make metrics exposed via JMX configurable

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9106

Core
KIP-551: Expose disk read and write metrics

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9292

Core









How to Contribute

Before code freeze:

...

Jira
serverASF JIRA
columnskey,priority,summary,type,assignee,status,created,updated,due,assignee,reporter,priority,status,resolution
maximumIssues20
jqlQueryproject = KAFKA AND fixVersion = 2.5.0 AND status not in (resolved, closed) ORDER BY priority DESC, status DESC, updated DESC
serverId5aa69414-a9e9-3523-82ec-879b028fb15b