...
- On topic creation
- On topic modification
- Change in topic config, via
AdminClient.alterConfigs()
(this change done as part of this KIP). - Adding partitions to topics, via
AdminClient.createPartitions()
(see KIP-195, but this change done as part of this KIP) - Reassigning partitions to brokers, and/or changing the replication factor via
AdminClient.reassignPartitions()
(see KIP-179) - KIP-113
- Change in topic config, via
- On topic deletion
...
Note: Unlike previous policy interfaces the inner RequestMetadata
is an interface rather than a class. This should simplify testing and better permit use sites to, for example, lazily fetch metadata when it's actually required by the policy implementation, rather than eagerly fetch information which the policy didn't actually require.
What other policies might there be in future? delete records policy
Deprecate existing policies
The existing CreateTopicPolicy
and AlterConfigPolicy
will be deprecated, but will continue to be applied when they are configured.
Using create.topic.policy.class.name
or alter.config.policy.class.name
will result in an deprecation warning in the broker logs.
...