屏蔽 kafka 连接器的日志

Question

我有一个属性文件，其中有一些秘密(凭据(和证书，我不想记录它们。 那么有没有办法将该凭据放在其他地方或不记录它们。 我们在阿帕奇卡夫卡中有一种叫做掩蔽的东西吗..？

Answer 1

如果您碰巧使用 KSQL 进行流式查询，请使用屏蔽函数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

文档来源在这里。