THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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-253277)
- Additional functionality in AdminClient including consumer group management and config management
- 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) |
|---|
| KIP-86: Configurable SASL callback handlers |
| Security |
| KIP- |
| Jira | ||||||
|---|---|---|---|---|---|---|
|
| 118: Drop Support for Java 7 |
| All |
| Jira | ||||||
|---|---|---|---|---|---|---|
|
| Jira | ||||||
|---|---|---|---|---|---|---|
|
| KIP-174 - Deprecate and remove internal converter configs in WorkerConfig |
| Connect | |||||||||
| KIP- |
| 176: Remove deprecated new-consumer option for tools |
|
|
| Tools |
| KIP-186: Increase offsets retention default to 7 days |
|
| Jira | ||||||
|---|---|---|---|---|---|---|
|
| 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 |