【发布时间】：2019-11-06 03:22:08
【问题描述】：
我正在使用 Spring Kafka，其中一个主题包含带有个人数据的消息。有什么方法可以将 Spring Kafka 配置为自动加密生产者中的消息/解密消费者中的消息，还是我必须手动执行？
【问题讨论】：
标签： spring-kafka
【发布时间】：2019-11-06 03:22:08
【问题描述】：
Spring 或 Kafka 没有内置任何内容（尽管您可以在线上使用 SSL 来防止窥探。
对于应用程序级加密/解密，您需要实现它。
您可以使用ProducerInterceptor 和ConsumerInterceptor (Kafka) 或RecordInterceptor (Spring) 将关注点与业务逻辑分开。
【讨论】：
-
干杯 Gary，我们需要应用程序级加密，因为我们计划使用 Amazon MSK。我将研究拦截器，spring 是否有等效的生产者拦截器？
-
否；它不是真的需要 - 我们添加
RecordInterceptor的原因是您可以一次拦截一个记录；ConsumerInterceptor为您提供poll()返回的完整记录集。我们的用户更喜欢一次一个的方法。在生产者方面，总是只有一条记录可以截获。 -
好的明白了，我来实现。感谢您的支持。