Kafka 消息加密主要通过以下方式确保消息的完整性：
- SSL/TLS 协议：使用 SSL/TLS 协议对数据进行传输加密，确保数据在传输过程中没有被窃听或篡改。SSL/TLS 协议提供了数据加密、身份验证和完整性保护的功能，是确保消息完整性的关键。
- SASL 认证：通过 SASL（Simple Authentication and Security Layer）机制进行客户端认证，确保只有经过验证的客户端才能与 Kafka 集群进行通信。这有助于防止未经授权的访问和数据泄露，间接保护消息的完整性。
- 消息摘要和签名：在应用层，可以为消息生成摘要和签名，通过验证签名来确认消息的完整性和来源。这种方法可以在不依赖 Kafka 自身加密机制的情况下，提供额外的安全层。
- 端到端加密：虽然 Kafka 本身不直接支持端到端加密，但可以在应用层实现，确保消息在传输过程中不被窃听或篡改，从而保证消息的完整性。
通过上述措施，Kafka 不仅能够保护消息的机密性，还能确保消息在传输过程中的完整性。