Если вы используете K SQL для потоковых запросов, вы используете функцию маскирования MASK()
.
CREATE STREAM MASKED_PURCHASES AS
SELECT MASK(CUSTOMER_NAME) AS CUSTOMER_NAME,
MASK_RIGHT(DATE_OF_BIRTH,12) AS DATE_OF_BIRTH,
ORDER_ID, PRODUCT, ORDER_TOTAL_USD, TOWN, COUNTRY
FROM PURCHASES;
ksql> SELECT CUSTOMER_NAME, DATE_OF_BIRTH, PRODUCT, ORDER_TOTAL_USD FROM MASKED_PURCHASES LIMIT 1;
Xxxxxx-Xxxxxx | 1908-03-nnXnn-nn-nnX | Langers - Mango Nectar | 5.80
Источник документации здесь .