Versions Compared

Key

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

...

Note: The planned content is not binding - final content will be based the features committed by branch-cutting date. See Kafka Improvement Proposals for the full list of KIPs.


KIPJIRAComponentCommitterComment
KIP-
81: Bound Fetch memory usage in the consumer

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

ClientsKIP-
183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient

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

Core, AdminClient
KIP-207: Offsets returned by ListOffsetsResponse should be monotonically increasing even during a partition leader change

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

Core
KIP-
258: Allow to Store Record Timestamps in RocksDB

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

StreamsKIP-
289: Improve the default group id behavior in KafkaConsumer

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

Clients

KIP-291: Separating controller connections and requests from the data plane

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

Core

KIP-313: Add KStream.flatTransform and KStream.flatTransformValues

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

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

Streamspartially implemented in v2.2
KIP-
328: Ability to suppress updates for KTables
367 Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)

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

6556

7391

Streamspartially implemented in v2.1KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde
Clients,AdminClient
KIP-368: Allow SASL Connections to Periodically Re-Authenticate

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

6161

7352

Core
Broker,
Streams
Clients
guozhang Wang

KIP-
339
371:
Create a new IncrementalAlterConfigs API
Add a configuration to build custom SSL principal name

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

7466

5462

Core
AminClientColin McCabe


KIP-
341: Update Sticky Assignor's User Data Protocol
376: Implement AutoClosable on appropriate classes that want to be used in a try-with-resource statement

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

7026

7402

Clients
Streams


KIP-
351: Add --under-min-isr option to describe topics command
377: TopicCommand to use AdminClient

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

7236

7433

Tools
AdminClient
Gwen Shapira

KIP-
359: Verify leader epoch in produce requests
380: Detect outdated control requests and bounced brokers using broker generation

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

7383Broker,Clients

7235

Core
Jason Gustafson


KIP-
361: Add Consumer Configuration to Disable Auto Topic Creation
386: Standardize on Min/Avg/Max metrics' default value

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

7320

7528

Clients,Streams


KIP-
367 Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)
389: Introduce a configurable consumer group size limit

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

7391

7641

Clients,AdminClient
Core
Colin McCabe


KIP-
368: Allow SASL Connections to Periodically Re-Authenticate
393: Time windowed serde to properly deserialize changelog input topic

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

7352Broker,Clients

7110

Streams
Rajini Sivaram


KIP-
371: Add a configuration to build custom SSL principal name
394: Require member.id for initial join group request

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

5462

7610

Core
Clients

KIP-
376: Implement AutoClosable on appropriate classes that want to be used in a try-with-resource statement
414: Expose Embedded ClientIds in Kafka Streams

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

7402

7798

Streams
KIP-
377: TopicCommand to use AdminClient
420: Add Single Value Fetch in Session Stores

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

Streams

Postponed to subsequent release

 

7433Colin McCabe
KIPJIRAComponentCommitterCommentAdminClient
KIP-379: Multiple Consumer Group Management81: Bound Fetch memory usage in the consumer

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

ToolsClients
KIP-380: Detect outdated control requests and bounced brokers using broker generation149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner

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

Streams


partially implemented in v1.1Core
KIP-386: Standardize on Min/Avg/Max metrics' default value-150 - Kafka-Streams Cogroup

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

Clients,Streams

KIP-389: Introduce a configurable consumer group size limit258: Allow to Store Record Timestamps in RocksDB

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

CoreStreams
KIP-393: Time windowed serde to properly deserialize changelog input topic313: Add KStream.flatTransform and KStream.flatTransformValues

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

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

Streamspartially implemented in v2.2
KIP-394: Require member.id for initial join group request328: Ability to suppress updates for KTables

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

Clients

6556

Streamspartially implemented in v2.1
KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and SerdeKIP-414: Expose Embedded ClientIds in Kafka Streams

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

Core, Streams
KIP-420: Add Single Value Fetch in Session StoresStreams

Postponed to subsequent release

 

339: Create a new IncrementalAlterConfigs API

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

AminClient
KIP-341: Update Sticky Assignor's User Data Protocol

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

Clients
KIP-351: Add --under-min-isr option to describe topics command

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

Tools
KIP-359: Verify leader epoch in produce requests
KIPJIRAComponentCommitterComment
KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner

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

Streamspartially implemented in v1.1Broker, Clients
KIP-361: Add Consumer Configuration to Disable Auto Topic Creation

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

Clients
KIP-379: Multiple Consumer Group ManagementKIP-150 - Kafka-Streams Cogroup

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

ToolsStreams