【Kafka】Kafka如何开启SSL 控制台消费与生产 代码消费与生产

在这里插入图片描述

1.概述

1.1.什么是Kafka权限认证?

在Kafka 0.9.0.0之后,Kafka社区增加了一系列的功能,其中包含对Kafka集群进行安全管控。支持的权限认证方式如下:

  1. Broker与Client之间的权限认证(例如Producer和Consumer)。可以使用SSL或SASL,而SASL支持如下方案:
    1. SASL/GSSAPI(Kerberos),开始于0.9.0.0版本
    2. SASL/PLAIN,开始于0.10.0.0版本
    3. SASL/SCRAM-SHA-256和SASL/SCRAM-SHA-512,开始于0.10.2.0版本
    4. SASL/OAUTHBEARER,开始于2.0版本
  2. Broker和Zookeeper之间建立权限认证
  3. 在Broker和Client之间、Broker和Broker之间使用SSL建立权限认证时,性能会有所下降,其程度取决于CPU类型和JVM的实现
  4. 对Client进行读写认证

在实际生产环境中,对于权限认证使用的较多的是SCRAM认证,其原因在《Kafka SCRAM和PLAIN实战》这篇博客中详细解释。

1.2 Kafka SSL安装与使用

Kafka允许客户端使用SSL来连接,默认情况下,SSL是禁止的,但是可以通过手动开启。安装Kafka SSL的流程如下所示:

猜你喜欢

转载自blog.csdn.net/qq_21383435/article/details/107852117