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

KIPJIRAComponent

KIP-150 - Kafka-Streams Cogroup

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

Streams

KIP-

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

352: Distinguish URPs caused by reassignment

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

-5295ConnectKIP-216: IQ should throw different exceptions for different errors

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

5876

8835

Streams
Core

KIP-

280: Enhanced log compaction

360: Improve reliability of idempotent/transactional producer

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

7061

8710

Core/Clients
KIP-
352: Distinguish URPs caused by reassignment
396: Add Reset/List Offsets Operations to AdminClient

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

8834

7689

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

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

-9059

-8587

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

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

8835

8345

Core
KIP-
360: Improve handling of unknown producer
511: Collect and Expose Client's Name and Version in the Brokers (new metrics)

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

8710

8855

Core/Clients
KIP-
396: Add Reset/List Offsets Operations to AdminClient
515: Enable ZK client to use the new TLS supported authentication

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

7689

8843

Clients
Core
KIP-
399
523:
Extend ProductionExceptionHandler to cover serialization exceptions
Add KStream#toTable to the Streams DSL

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

7499

7658

Streams
KIP-
401: TransformerSupplier/ProcessorSupplier StateStore connecting
524: Allow users to choose config source when describing configs

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

7523

9040

Streams
Core
KIP-
444: Augment metrics for Kafka Streams (some parts in 2.4, some TBD)
526: Reduce Producer Metadata Lookups for Large Number of Topics

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

6819

8904

Streams
Clients
KIP-
447: Producer scalability for exactly once semantics (partial)
527: Add VoidSerde to Serdes

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

8587

8455

Streams
KIP-
455: Create an Administrative API for Replica Reassignment
530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'

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

8345

8953

Core
Streams
KIP-
467: Augment ProduceResponse error messaging for specific culprit records
531: Drop support for Scala 2.11 in Kafka 2.5

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

8729

9324

Core
/Clients
KIP-
511: Collect and Expose Client's Name and Version in the Brokers (new metrics)
535: Allow state stores to serve stale reads during rebalance

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

8855

6144

Core/Clients
Streams
KIP-
514: Add a bounded flush() API to Kafka Producer
537: Increase default zookeeper session timeout

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

7711

9102

Clients
Core
KIP-
515: Enable ZK client to use the new TLS supported authentication
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-

8843

9091

Core
KIP-
523: Add KStream#toTable to the Streams DSL
541: Create a fetch.max.bytes configuration for the broker

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

7658

9101

Streams
Core
KIP-
524: Allow users to choose config source when describing configs
543: Expand ConfigCommand's non-ZK functionality

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

9040

9082

Core
KIP-
526: Reduce Producer Metadata Lookups for Large Number of Topics
553: Disable all SSL protocols except TLSV1.2 by default.

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

8904

9460

Clients
Core
KIP-
527: Add VoidSerde to Serdes
555: Deprecate Direct Zookeeper access in Kafka Administrative Tools (partial in 2.5)

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

8455

9397

Streams
Core
KIP-
530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'
558: Track the set of actively used topics by connectors in Kafka Connect

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

8953

9422

Streams
Connect
KIP-
531: Drop support for Scala 2.11 in Kafka 2.5
559: Make the Kafka Protocol Friendlier with L7 Proxies

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

9324

9437

Core
KIP-
537: Increase default zookeeper session timeout
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-

9102

9445

Streams


Postponed KIPs

KIPJIRAComponent
Core
KIP-
538: Add a metric tracking the number of open connections with a given SSL cipher type
158: Kafka Connect should allow source connectors to set topic-specific settings for new topics

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

9091

5295

Core
Connect
KIP-
541: Create a fetch.max.bytes configuration for the broker
216: IQ should throw different exceptions for different errors

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

9101

5876

Core
Streams

KIP-

543: Expand ConfigCommand's non-ZK functionality

280: Enhanced log compaction

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

9082

7061

Core
KIP-
544: Make metrics exposed via JMX configurable
399: Extend ProductionExceptionHandler to cover serialization exceptions

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

9106

7499

Core
Streams
KIP-
551: Expose disk read and write metrics
401: TransformerSupplier/ProcessorSupplier StateStore connecting

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

9292

7523

Core
Streams
KIP-
553: Disable all SSL protocols except TLSV1.2 by default.
444: Augment metrics for Kafka Streams (some parts in 2.4, some TBD)

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

9460

6819

Core
Streams
KIP-
555: Deprecate Direct Zookeeper access in Kafka Administrative Tools
467: Augment ProduceResponse error messaging for specific culprit records

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

9397

8729

Core/Clients
KIP-
558: Track the set of actively used topics by connectors in Kafka Connect
514: Add a bounded flush() API to Kafka Producer

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

9422

7711

Connect
Clients
KIP-
559
544: Make
the Kafka Protocol Friendlier with L7 Proxies
metrics exposed via JMX configurable

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

9437

9106

Core
KIP-
562: Allow fetching a key from a single partition rather than iterating over all the stores on an instance
551: Expose disk read and write metrics

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

9445

9292

Streams

Postponed KIPs

...

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