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-

5876StreamsKIP-280: Enhanced log compaction

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

7061

8835

Core

KIP-

352: Distinguish URPs caused by reassignment

360: Improve reliability of idempotent/transactional producer

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

8834

8710

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

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

-9059

-7689

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

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

8835

8587

Core
Streams
KIP-
360: Improve handling of unknown producer
455: Create an Administrative API for Replica Reassignment

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

8710

8345

Core
/Clients
KIP-
396: Add Reset/List Offsets Operations to AdminClient
511: Collect and Expose Client's Name and Version in the Brokers (new metrics)

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

7689

8855

Core/Clients
KIP-
399: Extend ProductionExceptionHandler to cover serialization exceptions
515: Enable ZK client to use the new TLS supported authentication

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

7499

8843

Streams
Core
KIP-
401: TransformerSupplier/ProcessorSupplier StateStore connecting
523: Add KStream#toTable to the Streams DSL

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

7523

7658

Streams
KIP-
444: Augment metrics for Kafka Streams (some parts in 2.4, some TBD)
524: Allow users to choose config source when describing configs

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

6819

9040

Streams
Core
KIP-
447
526: Reduce Producer
scalability for exactly once semantics (partial)
Metadata Lookups for Large Number of Topics

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

8587

8904

Streams
Clients
KIP-
455: Create an Administrative API for Replica Reassignment
527: Add VoidSerde to Serdes

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

8345

8455

Core
Streams
KIP-
467: Augment ProduceResponse error messaging for specific culprit records
530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'

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

8729

8953

Core/Clients
Streams
KIP-
511: Collect and Expose Client's Name and Version in the Brokers (new metrics)
531: Drop support for Scala 2.11 in Kafka 2.5

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

8855

9324

Core
/Clients
KIP-
514: Add a bounded flush() API to Kafka Producer
535: Allow state stores to serve stale reads during rebalance

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

7711

6144

Clients
Streams
KIP-
515: Enable ZK client to use the new TLS supported authentication
537: Increase default zookeeper session timeout

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

8843

9102

Core
KIP-
523
538: Add
KStream#toTable to the Streams DSL
a metric tracking the number of open connections with a given SSL cipher type

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

7658

9091

Streams
Core
KIP-
524: Allow users to choose config source when describing configs
541: Create a fetch.max.bytes configuration for the broker

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

9040

9101

Core
KIP-
526: Reduce Producer Metadata Lookups for Large Number of Topics
543: Expand ConfigCommand's non-ZK functionality

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

8904

9082

Clients
Core
KIP-
527: Add VoidSerde to Serdes
553: Disable all SSL protocols except TLSV1.2 by default.

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

8455

9460

Streams
Core
KIP-
530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'
555: Deprecate Direct Zookeeper access in Kafka Administrative Tools (partial in 2.5)

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

8953

9397

Streams
Core
KIP-
531: Drop support for Scala 2.11 in Kafka 2.5
558: Track the set of actively used topics by connectors in Kafka Connect

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

9324

9422

Core
Connect
KIP-
535: Allow state stores to serve stale reads during rebalance
559: Make the Kafka Protocol Friendlier with L7 Proxies

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

6144

9437

Streams
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