THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
I propose to introduce the
org.apache.kafka.common.Record
- new public interface. Expose information about Records to be added to the topic.org.apache.kafka.server.policy.RecordsPolicy
- new public interface. Implementation of this interface contains specific logic to check records to be added to the topic.records.policy.class.name: String -
Configuration option - sets class name of the implementation ofRecordsPolicy
for the specific topic.records.policy.enabled: Boolean
- Configuration option - enable or disable records policy for the topic
...