THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- new public interface
RecordsPolicy. - Configuration option -
records.policy.class.name: String -sets class name of the implementation ofRecordsPolicyfor the specific topic. - Configuration option -
records.policy.enabled: Boolean- enable or disable records policy for the topic
If records.policy.enabled = true than an instance of the RecordsPolicy should check each Records batch before applying data to the log.
If PolicyViolationException thrown from the validate methods then no data added to the log and the client receives an error.
Compatibility, Deprecation, and Migration Plan
...
No migration required.
Rejected Alternatives
-