Policy | Description |
---|---|
ProducePolicyPlugin | Ensures produced messages adhere to configuration requirements. Parameters configure Block acks -1 and audit compression (GZIP, ZSTD, etc). |
EncryptPlugin | Encrypts full payloads for topics matching pattern: .*_encrypted$ . Check the customers_encrypted topic in the local-kafka cluster. |
DecryptPlugin | Decrypts payloads on consume for topics matching .*_encrypted$ . Shows plaintext in cdk-gateway . |
FieldLevelDataMaskingPlugin | Masks profile.creditCardNumber , contact.email and contact.phone in topics matching pattern: ^[A-Za-z]*_masked$ . |
CreateTopicPolicyPlugin | Validates topic config: partitions have to be 1–3 or creation is Blocked. |