屏蔽kafka连接器的日志

【问题标题】：Masking the logs of kafka connector屏蔽kafka连接器的日志
【发布时间】：2020-12-04 23:30:27
【问题描述】：

我有一个属性文件，其中有一些秘密（凭据）和证书，我不想记录它们。那么有什么方法可以将该凭据放在其他地方或不记录它们。我们在 apache kafka 中有什么叫做掩码的东西吗？

【问题讨论】：

你指的是哪个设置？为什么要记录凭据？

【解决方案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

文档来源是here。

【讨论】：