...
This is a list of key features/improvements/bugfixes that we can include with release notes (WIP):
- In-order delivery with partition expansion Prefixed wildcard ACLs (KIP-290), Fine grained ACLs for CreateTopics (KIP-253)Additional functionality in AdminClient including consumer group management and config management277)
- SASL/OAUTHBEARER implementation (KIP-255)
- Improved quota communication and customization of quotas (KIP-219, KIP-257)
- Efficient memory usage for down conversion (KIP-283)
- Fix log divergence between leader and follower during fast leader failover (KIP-279)
- Drop support for Java 7 and remove deprecated code (e.g old scala clients)
- Connect REST extension plugin, support for externalizing secrets and improved error handling (KIP-285, KIP-297, KIP-298 etc.)
- Scala API for Kafka Streams and other Streams API improvements (KIP-270, KIP-150, KIP-245, KIP-251 etc.)
...
Also feel free to refer to this release page for more details of the included tickets.
...
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.
Jira | ||||||
---|---|---|---|---|---|---|
|
KIP | JIRA | Component | Committer |
---|
(reviewer) |
---|
Jira | ||||||
---|---|---|---|---|---|---|
|
KIP-86: Configurable SASL callback handlers |
| Security |
KIP-118: Drop Support for Java 7 |
| All |
Jira | ||||||
---|---|---|---|---|---|---|
|
KIP-174 - Deprecate and remove internal converter configs in WorkerConfig |
| Connect | |||||||||
KIP- |
176: Remove deprecated new-consumer option for tools |
|
|
Tools |
Jira | ||||||
---|---|---|---|---|---|---|
|
KIP-186: Increase offsets retention default to 7 days |
| Broker |
KIP-219 - Improve quota communication |
| Broker,Clients |
KIP-222 - Add Consumer Group operations to Admin API |
| AdminClient |
KIP-223 - Add per-topic min lead and per-partition lead metrics to KafkaConsumer |
| Consumer |
KIP-237: More Controller Health Metrics |
| Broker | |||||||||
KIP-244: Add Record Header support to Kafka Streams Processor API |
| Streams |
KIP-245: Use Properties instead of StreamsConfig in KafkaStreams constructor |
| Streams |
KIP-249: Add Delegation Token Operations to KafkaAdminClient |
| AdminClient |
KIP-251: Allow timestamp manipulation in Processor API |
| Streams |
KIP-255 OAuth Authentication via SASL/OAUTHBEARER |
| Security |
KIP-257 - Configurable Quota Management |
| Broker |
KIP-261: Add Single Value Fetch in Window Stores |
| Streams |
KIP-265: Make Windowed Serde to public APIs |
| Streams |
KIP-266: Fix consumer indefinite blocking behavior |
| Consumer |
KIP-267: Add Processor Unit Test Support to Kafka Streams Test Utils |
| Streams |
KIP-268: Simplify Kafka Streams Rebalance Metadata Upgrade |
| Streams | |||||||||
KIP-270 - A Scala Wrapper Library for Kafka Streams |
| Streams |
KIP-272: Add API version tag to broker's RequestsPerSec metric |
| Broker |
KIP-274: Kafka Streams Skipped Records Metrics |
| Streams | |||||||||
KIP-276 Add StreamsConfig prefix for different consumers |
| Streams |
KIP-277 - Fine Grained ACL for CreateTopics API |
| Security | |||||||||
KIP-278 - Add version option to Kafka's commands |
| Tools |
KIP-279: Fix log divergence between leader and follower after fast leader fail over |
| Broker |
KIP-281: ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User |
| Tools | Jason Gustafson | ||||||||
KIP-282: Add the listener name to the authentication context |
| Security | |||||||||
KIP-283: Efficient Memory Usage for Down-Conversion |
| Broker | |||||||||
KIP-284: Set default retention ms for Streams repartition topics to Long.MAX_VALUE |
| Streams |
KIP-285: Connect Rest Extension Plugin |
| Connect | |||||||||
KIP-290: Support for Prefixed ACLs |
| Security | Jun Rao | ||||||||
KIP-292: Add transformValues() method to KTable |
| Streams | |||||||||
KIP-294 - Enable TLS hostname verification by default |
| Security | |||||||||
KIP-295: Add Streams Configuration Allowing for Optional Topology Optimization |
| Streams | |||||||||
KIP-297: Externalizing Secrets for Connect Configurations |
| Connect | |||||||||
KIP-298: Error Handling in Connect |
| Connect | |||||||||
KIP-303: Add Dynamic Routing in Streams Sink |
| Streams | |||||||||
KIP-305: Add Connect primitive number converters |
| Connect |
Postponed to subsequent release
KIP | JIRA | Component | Committer | ||||||||
---|---|---|---|---|---|---|---|---|---|---|---|
KIP-81: Bound Fetch memory usage in the consumer |
| Consumer | |||||||||
KIP-91 Provide Intuitive User Timeouts in The Producer |
| Producer | |||||||||
KIP-150 - Kafka-Streams Cogroup |
| Streams | |||||||||
KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics |
| Connect | |||||||||
KIP-183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient |
| AdminClient | |||||||||
KIP-206: Add support for UUID serialization and deserialization |
| Clients | Ewen Cheslack-Postava | ||||||||
KIP-207: Offsets returned by ListOffsetsResponse should be monotonically increasing even during a partition leader change |
| Broker | |||||||||
KIP-211: Revise Expiration Semantics of Consumer Group Offsets |
| Consumer | Jason Gustafson | ||||||||
KIP-235: Add DNS alias support for secured connection |
| Clients | Ismael Juma Juma | ||||||||
KIP-306: Configuration for Delaying Response to Failed Client Authentication |
| Broker | Rajini Sivaram |