DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
| Table of Contents |
|---|
Status
Current state: Voting Accepted
Discussion thread: https://lists.apache.org/thread/7y7svyp3f560fzv1bgcr893vn258cn06
...
- Backward Compatibility: change is fully backward compatible. Existing custom
StreamPartitionerimplementations will continue to work as they will use the default implementation of the new method. - Deprecation: Deprecate non-headers public methods to be able to remove them in Kafka
5.0 - Migration: Users wishing to leverage headers in their custom partitioning logic should migrate their
StreamPartitionerimplementations to override the new `partitions` method. - Functional interface migration:
StreamPartitioneris a functional interface that currently exposes headerless methods, which are going to be deprecated. Users will be notified about using the deprecated API, and they will need to implement the interface directly instead of using lambda syntax. However, they can return to using the functional style partitioner once the deprecated methods are completely removed, which is planned for Kafka5.0
...