Versions Compared

Key

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

...

  • SASL support improvement (KIP-342, KIP-368)
  • Admin script and admin client API improvements to simplify admin operation (KIP-231, KIP-308, KIP-322, KIP-324, KIP-338, KIP-340)
  • Streams API improvements (KIP-319, KIP-321, KIP-330, KIP-353, KIP-356, KIP-372)
  • Avoid expiring committed offsets for active consumer group (KIP-211)
  • Provide Intuitive User Timeouts in The Producer (KIP-91)

...

KIPJIRAComponentCommitter (reviewer)

KIP-91 Provide Intuitive User Timeouts in The Producer

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

Clients
KIP-206: Add support for UUID serialization and deserialization

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

Clients
KIP-211: Revise Expiration Semantics of Consumer Group Offsets

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

Broker,Clients
KIP-231: Improve the Required ACL of ListGroups API

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

Security
KIP-306: Configuration for Delaying Response to Failed Client Authentication

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

Client
KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs

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

Broker
KIP-312: Add Overloaded StreamsBuilder Build Method to Accept java.util.Properties

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

Streams
KIP-319: Replace segments with segmentInterval in WindowBytesStoreSupplier

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

Streams
KIP-321: Update TopologyDescription to better represent Source and Sink Nodes

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

Streams
KIP-322: Return new error code for DeleteTopics API when topic deletion disabled

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

Tools
KIP-324: Add method to get metrics() in AdminClient

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

AdminClient
KIP-330: Add retentionPeriod in SessionBytesStoreSupplier

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

Streams
KIP-332: Update AclCommand to use AdminClient API

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

Tools
KIP-336: Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer

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

Clients
KIP-338 Support to exclude the internal topics in kafka-topics.sh command

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

Tools
KIP-340: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file

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

Tools
KIP-342: Add support for Custom SASL extensions in OAuthBearer authentication

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

Security
KIP-353: Improve Kafka Streams Timestamp Synchronization

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

Streams
KIP-356: Add withCachingDisabled() to StoreBuilder

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

StreamsMatthias Sax
KIP-357: Add support to list ACLs per principal

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

Tools
KIP-365: Materialized, Serialized, Joined, Consumed and Produced with implicit Serde

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

Streams
KIP-366: Make FunctionConversions deprecated

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

StreamsKIP-368: Allow SASL Connections to Periodically Re-Authenticate

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

Broker,Clients
KIP-372: Naming Repartition Topics for Joins and Grouping

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

Streams

...

 

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

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

Clients
KIP-110: Add Codec for ZStandard Compression

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

Broker,Clients
KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner

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

Streams
KIP-150 - Kafka-Streams Cogroup

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

Streams
KIP-289: Improve the default group id behavior in KafkaConsumer

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

Clients
KIP-302 - Enable Kafka clients to use all DNS resolved IP addresses

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

Clients

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

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

Streams
KIP-320: Allow fetchers to detect and handle log truncation

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

Broker,Clients
KIP-328: Ability to suppress updates for KTables

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

Streams
KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde

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

Core, Streams
KIP-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-358: Migrate Streams API to Duration instead of long ms times

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

Streams
KIP-359: Verify leader epoch in produce requests

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

Broker,Clients
KIP-361: Add Consumer Configuration to Disable Auto Topic Creation

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

Clients
KIP-367 Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)

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

Clients,AdminClient
KIP-368: Allow SASL Connections to Periodically Re-Authenticate

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

Broker,Clients