大数据处理中 Kafka 的安全配置与防护

客户端连接broker时,会先验证broker的身份(通过证书);双方协商生成一个“会话密钥”,后续所有数据都用这个密钥加密传输。SASL是Kafka的认证框架PLAIN:简单用户名密码(明文传输,仅...
4周前
110

Kafka 消息过期时间设置与清理机制全解析

在消息中间件的实际应用中,消息过期是一个绕不开的话题。无论是日志数据的定期清理、业务事件的临时存储,还是磁盘空间的合理管控,都需要一个完善的消息过期机制。Kafka 作为高吞吐的分布式消息系统,提供了...
4周前
120

Apache Kafka 是什么?

Apache Kafka是一个开源的分布式事件流平台,具有高吞吐、持久化、可扩展等特点。其核心概念包括主题、分区、副本等,架构围绕生产、存储、消费三个环节设计,支持高吞吐、低延迟的消息处理。Kafka...
4周前
120