Page History

...

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 of RecordsPolicy for the specific topic.
• records.policy.enabled: Boolean  - Configuration option - enable or disable records policy for the topic

...