Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • KIP Freeze: May 20, 2020 (a KIP must be accepted by this date in order to be considered for this release)
  • Feature Freeze: May 27, 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: June 10, 2020
  • Release: June 24, 2020 (Actual release: August 3, 2020)


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.

...

KIPJIRAComponent
KIP-131 - Add access to OffsetStorageReader from SourceConnector

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

Connect
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-221: Enhance DSL with Connecting Topic Creation and Repartition Hint

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

Streams
KIP-401: TransformerSupplier/ProcessorSupplier StateStore connecting

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

Streams
KIP-437: Custom replacement for MaskField SMT

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

Connect
KIP-441: Smooth Scaling Out for Kafka Streams (additional parts in 2.6)

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8019
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7149
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6145
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-4696

Streams
KIP-444: Augment metrics for Kafka Streams (additional parts in 2.6)

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9753
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9230
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8856
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7963
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6820
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6819
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5676

Streams
KIP-446: Add changelog topic configuration to KTable suppress

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

Streams
KIP-447: Producer scalability for exactly once semantics (remainder in 2.6)

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

Streams
KIP-518: Allow listing consumer groups per state

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

Core/Clients
KIP-519: Make SSL context/engine configuration extensible

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

Core/Clients
KIP-546: Add Client Quota APIs to the Admin Client (remainder in 2.6)

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

Core/Clients
KIP-551: Expose disk read and write metrics

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

Core
KIP-557: Add emit on change support for Kafka Streams (partially complete in 2.6)

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

Streams
KIP-568: Explicit rebalance triggering on the Consumer

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

Core/Clients
KIP-569: DescribeConfigsResponse - Update the schema to include additional metadata information of the field

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

Core/Clients
KIP-570: Add leader epoch in StopReplicaRequest

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

Core
KIP-571: Add option to force remove members in StreamsResetter

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

Streams
KIP-573: Enable TLSv1.3 by default

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

Core/Clients
KIP-574: CLI Dynamic Configuration with file input

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

Core
KIP 577: Allow HTTP Response Headers to be Configured for Kafka Connect

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

Connect
KIP-585: Filter and Conditional SMTs

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

Connect
KIP-586: Deprecate commit records without record metadata

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

Connect
KIP-605: Expand Connect Worker Internal Topic Settings594: Expose output topic names from TopologyTestDriver

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

ConnectStreams
KIP-606: Add Metadata Context to MetricsReporter602: Change default value for client.dns.lookup

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

Core/Connect/StreamsClients
KIP-610: Error Reporting in Sink Connectors

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

ConnectKIP-613: Add end-to-end latency metrics to Streams604: Remove ZooKeeper Flags from the Administrative Tools (partially complete in 2.6)

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

Streams

...

KIP-81: Bound Fetch memory usage in the consumer4133Clients280: Enhanced log compaction7061359: Verify leader epoch in produce requests7383Core444: Augment metrics for Kafka remainder9753

10104

Clients
KIPJIRAComponent-605: Expand Connect Worker Internal Topic Settings

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

9931

Connect
KIP-606: Add Metadata Context to MetricsReporter

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

9960

Core/Connect/Streams
KIP-610: Error Reporting in Sink Connectors

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

9971

Connect
KIP-613: Add end-to-end latency metrics to Streams (partially complete in 2.6)

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

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

Streams


Postponed KIPs

KAFKA-8856
KIPJIRAComponent
KIP-81: Bound Fetch memory usage in the consumer9230
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
key

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

Clients
KIP-280: Enhanced log compaction

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

Core
KIP-359: Verify leader epoch in produce requests

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

StreamsCore
KIP-466: Add support for List<T> serialization and deserialization

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

Streams/Clients
KIP-497: Add inter-broker API to alter ISR

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

Core
KIP-557: Add emit on change support for Kafka Streams (remainder)

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

Streams
KIP-580: Exponential Backoff for Kafka Clients

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

Core/Clients
KIP-584: Versioning scheme for features

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

Core/Clients
KIP-588: Allow producers to recover gracefully from transaction timeouts

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

Core/Clients
KIP-604: Remove ZooKeeper Flags from the Administrative Tools (remainder)

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

Clients
KIP-608 - Expose Kafka Metrics in Authorizer

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

Core
KIP-611: Improved Handling of Abandoned Connectors and Tasks

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

Connect
KIP-612: Ability to Limit Connection Creation Rate on Brokers

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

Core
KIP-613: Add end-to-end latency metrics to Streams (remainder)

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

Streams



...