Kafka 原生支持的是通过 SSL/TLS 加密传输数据,而不是所谓的 “plaintext” 传输。如果你想要在 Kafka 中使用加密传输,你应该配置 SSL/TLS。
以下是一个基本的 Kafka SSL/TLS 配置示例:
openssl
生成私钥、公钥和证书签名请求(CSR)。server.properties
文件,添加或修改以下配置项:listeners=SSL://:9093
security.inter.broker.protocol=SSL
ssl.truststore.location=/path/to/truststore.jks
ssl.truststore.password=truststore-password
ssl.keystore.location=/path/to/keystore.jks
ssl.keystore.password=keystore-password
ssl.key.password=key-password
ssl.enabled.protocols=TLSv1.2
ssl.protocol=TLS
请注意,上述示例中的路径和密码应替换为你自己的实际值。此外,为了确保安全性,建议使用强密码、定期更新证书以及遵循最佳的安全实践。
如果你指的是不使用任何加密的 “plaintext” 传输(这在生产环境中是不推荐的),那么 Kafka 原生并不支持这种模式。在任何情况下,都应考虑使用 SSL/TLS 或其他加密方法来保护数据传输。