Versions Compared

Old Version 37

changes.mady.by.user David Arthur

Saved on

compared with

New Version Current

changes.mady.by.user David Arthur

Saved on

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.

...

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-5295

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

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

StreamsKIP-280: Enhanced log compaction

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

Core

KIP-352: Distinguish URPs caused by reassignment360: Improve reliability of idempotent/transactional producer

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

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-88358587

CoreStreams
KIP-360: Improve handling of unknown producer455: Create an Administrative API for Replica Reassignment

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

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

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

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

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

StreamsCore
KIP-401: TransformerSupplier/ProcessorSupplier StateStore connecting523: Add KStream#toTable to the Streams DSL

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

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-68199040

StreamsCore
KIP-447526: Reduce Producer scalability for exactly once semantics (partial)Metadata Lookups for Large Number of Topics

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

StreamsClients
KIP-455: Create an Administrative API for Replica Reassignment527: Add VoidSerde to Serdes

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

CoreStreams
KIP-467: Augment ProduceResponse error messaging for specific culprit records530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'

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

Core/ClientsStreams
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-88559324

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

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

ClientsStreams
KIP-515: Enable ZK client to use the new TLS supported authentication537: Increase default zookeeper session timeout

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

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

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

StreamsCore
KIP-524: Allow users to choose config source when describing configs541: Create a fetch.max.bytes configuration for the broker

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

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

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

ClientsCore
KIP-527: Add VoidSerde to Serdes553: Disable all SSL protocols except TLSV1.2 by default.

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

StreamsCore
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-89539397

StreamsCore
KIP-531: Drop support for Scala 2.11 in Kafka 2.5558: Track the set of actively used topics by connectors in Kafka Connect

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

CoreConnect
KIP-535: Allow state stores to serve stale reads during rebalance559: Make the Kafka Protocol Friendlier with L7 Proxies

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

StreamsCore
KIP-537: Increase default zookeeper session timeout562: 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

Core

9445

Streams


Postponed KIPs

538: Add a metric tracking the number of open connections with a given SSL cipher type9091Core541: Create a fetch.max.bytes configuration for the broker9101Core543: Expand ConfigCommand's non-ZK functionality9082544: Make metrics exposed via JMX configurable9106Core551: Expose disk read and write metrics9292Core553: Disable all SSL protocols except TLSV1.2 by default.9460Core555: Deprecate Direct Zookeeper access in Kafka Administrative Tools9397558: Track the set of actively used topics by connectors in Kafka Connect9422Connect559 the Kafka Protocol Friendlier with L7 Proxies9437562: Allow fetching a key from a single partition rather than iterating over all the stores on an instance9445
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

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