使用 Spring Kafka 加密和解密消息

Question

我正在使用 Spring Kafka，其中一个主题包含带有个人数据的消息。有什么方法可以配置 Spring Kafka 自动加密消费者 Producer/decrypt 消息中的消息，还是我必须手动执行？

Answer 1

Spring 或 Kafka 没有内置任何内容（尽管您可以在线上使用 SSL 来防止窥探。

对于应用程序级别 encryption/decryption，您需要实现它。

您可以使用 ProducerInterceptor 和 ConsumerInterceptor (Kafka) 或 RecordInterceptor (Spring) 将问题与业务逻辑分开。