Confluent Connectors Portfolio
How to Protect PII in Kafka With Schema Registry and Data Contracts

How to Protect PII in Kafka With Schema Registry and Data Contracts

8/20/2025 · Robert Yokota

What this post added

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).

Read the original post ↗