| KIP | JIRA | Component | Committer | Comment |
|---|
| KIP-81: Bound Fetch memory usage in the consumer | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4133 |
|---|
|
| Clients | |
|
| KIP-183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-5692 |
|---|
|
| Core, AdminClient | |
|
| KIP-207: Offsets returned by ListOffsetsResponse should be monotonically increasing even during a partition leader change | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-2334 |
|---|
|
| Core | |
|
| KIP-258: Allow to Store Record Timestamps in RocksDB | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-3522 |
|---|
|
| Streams | |
|
| KIP-289: Improve the default group id behavior in KafkaConsumer | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-6774 |
|---|
|
| Clients |
|
|
KIP-313: Add KStream.flatTransform and KStream.flatTransformValues
| | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4217 |
|---|
|
| Streams | |
|
| KIP-328: Ability to suppress updates for KTables | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-6556 |
|---|
|
| Streams | | partially implemented in v2.1 |
| KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-6161 |
|---|
|
| Core, Streams | |
|
| KIP-339: Create a new IncrementalAlterConfigs API | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7466 |
|---|
|
| AminClient | |
|
| KIP-341: Update Sticky Assignor's User Data Protocol | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7026 |
|---|
|
| Clients | |
|
| KIP-351: Add --under-min-isr option to describe topics command | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7236 |
|---|
|
| Tools | |
|
| KIP-359: Verify leader epoch in produce requests | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7383 |
|---|
|
| Broker,Clients | |
|
| KIP-361: Add Consumer Configuration to Disable Auto Topic Creation | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7320 |
|---|
|
| Clients | |
|
| KIP-367 Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit) | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7391 |
|---|
|
| Clients,AdminClient | |
|
| KIP-368: Allow SASL Connections to Periodically Re-Authenticate | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7352 |
|---|
|
| Broker,Clients | |
|
| KIP-371: Add a configuration to build custom SSL principal name | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-5462 |
|---|
|
| Core |
|
|
| KIP-376: Implement AutoClosable on appropriate classes that want to be used in a try-with-resource statement | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7402 |
|---|
|
| Streams |
|
|
| KIP-377: TopicCommand to use AdminClient | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7433 |
|---|
|
| AdminClient | |
|
| KIP-380: Detect outdated control requests and bounced brokers using broker generation | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7235 |
|---|
|
| Core |
|
|
| KIP-386: Standardize on Min/Avg/Max metrics' default value | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7528 |
|---|
|
| Clients,Streams |
|
|
| KIP-393: Time windowed serde to properly deserialize changelog input topic | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7110 |
|---|
|
| Streams |
|
|
| KIP-394: Require member.id for initial join group request | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7610 |
|---|
|
| Clients |
|
|
| KIP-414: Expose Embedded ClientIds in Kafka Streams | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-7798 |
|---|
|
| Streams | |
|