THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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.
| KIP | JIRA | Component | Committer | Comment |
|---|---|---|---|---|
| KIP- |
| Jira | ||||||
|---|---|---|---|---|---|---|
|
| 183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient |
| Core, AdminClient | ||||||||||
| KIP-207: Offsets returned by ListOffsetsResponse should be monotonically increasing even during a partition leader change |
| Core | ||||||||||
| KIP- |
| Jira | ||||||
|---|---|---|---|---|---|---|
|
| 289: Improve the default group id behavior in KafkaConsumer |
| Clients | ||||||||||||||||||
| KIP-291: Separating controller connections and requests from the data plane |
| Core | ||||||||||||||||||
KIP-313: Add KStream.flatTransform and KStream.flatTransformValues |
| Streams | partially implemented in v2.2 | |||||||||||||||||
| KIP- |
| 367 Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit) |
|
|
| Clients,AdminClient | |||||||||
| KIP-368: Allow SASL Connections to Periodically Re-Authenticate |
|
|
| Broker, |
| Clients |
| KIP- |
| 371: |
| Add a configuration to build custom SSL principal name |
|
| Core |
| KIP- |
| 376: Implement AutoClosable on appropriate classes that want to be used in a try-with-resource statement |
|
|
| Streams |
| KIP- |
| 377: TopicCommand to use AdminClient |
|
|
| AdminClient |
| KIP- |
| 380: Detect outdated control requests and bounced brokers using broker generation |
|
| Core |
| KIP- |
| 386: Standardize on Min/Avg/Max metrics' default value |
|
| Clients,Streams |
| KIP- |
| 389: Introduce a configurable consumer group size limit |
|
|
| Core |
| KIP- |
| 393: Time windowed serde to properly deserialize changelog input topic |
|
| Streams |
| KIP- |
| 394: Require member.id for initial join group request |
|
|
| Clients | ||
| KIP- |
| 414: Expose Embedded ClientIds in Kafka Streams |
|
| Streams | ||||
| KIP- |
| 420: Add Single Value Fetch in Session Stores |
| Streams |
Postponed to subsequent release
| KIP | JIRA | Component | Committer | Comment | 7433AdminClient | Colin McCabe|||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| KIP-379: Multiple Consumer Group Management81: Bound Fetch memory usage in the consumer |
| ToolsClients | ||||||||||||||||||
| KIP-380: Detect outdated control requests and bounced brokers using broker generation149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner |
| Streams | partially implemented in v1.1Core | |||||||||||||||||
| KIP-386: Standardize on Min/Avg/Max metrics' default value-150 - Kafka-Streams Cogroup |
| Clients,Streams | ||||||||||||||||||
| KIP-389: Introduce a configurable consumer group size limit258: Allow to Store Record Timestamps in RocksDB |
| CoreStreams | ||||||||||||||||||
| KIP-393: Time windowed serde to properly deserialize changelog input topic313: Add KStream.flatTransform and KStream.flatTransformValues |
| Streams | partially implemented in v2.2 | |||||||||||||||||
| KIP-394: Require member.id for initial join group request328: Ability to suppress updates for KTables |
| Clients |
| Streams | partially 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 |
| Core, Streams | ||||||||||||||||||
| KIP-420: Add Single Value Fetch in Session Stores | Streams |
Postponed to subsequent release
| 339: Create a new IncrementalAlterConfigs API |
| AminClient | ||||||||||||
| KIP-341: Update Sticky Assignor's User Data Protocol |
| Clients | ||||||||||||
| KIP-351: Add --under-min-isr option to describe topics command |
| Tools | ||||||||||||
| KIP-359: Verify leader epoch in produce requests | ||||||||||||||
| KIP | JIRA | Component | Committer | Comment | ||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner |
| Streams | partially implemented in v1.1 | Broker, Clients | ||||||||||
| KIP-361: Add Consumer Configuration to Disable Auto Topic Creation |
| Clients | ||||||||||||
| KIP-379: Multiple Consumer Group ManagementKIP-150 - Kafka-Streams Cogroup |
| Tools | Streams |