How to Protect PII in Kafka With Schema Registry and Data Contracts
Aug 20, 2025Robert Yokota

Summary
Introduces PII protection strategies within Kafka using Schema Registry data contracts. Demonstrates ensuring data quality of PII fields with CEL expressions, capturing invalid data in Dead Letter Queues (DLQs), performing simple masking of PII using CEL functions, and encrypting PII with client-side field-level encryption (CSFLE).