生产环境中要求java发送消息到kafka和从kafka中消费数据都需要进行安全性校验，有没有什么方案？

// 消息指纹校验
public class MessageWrapper {
    private String payload;
    private String checksum; // SHA256(payload + salt)
}
// 生产者端
String salt = "kafka-secure-2023";
String checksum = DigestUtils.sha256Hex(payload + salt);
template.send("topic", new MessageWrapper(payload, checksum));
// 消费者端
if (!DigestUtils.sha256Hex(message.getPayload() + salt).equals(message.getChecksum())) {
    throw new InvalidMessageException();
}