apache-kafka-security相关内容

Kafka Java使用者SSL握手错误:java.security.cert.cerfiateException:不存在使用者替代名称

我正在运行Kafka 2.13-2.4.1,并在用Java编写的Kafka客户端(消费者)和Kafka集群(3个节点,每个节点有一个Broker)之间配置一个SSL连接。 我通过Confluent's Documentation使用官方文档,它有单向身份验证(客户端没有证书),它不起作用,所以我不得不使用两种方式进行身份验证,然后消费者和生产者控制台都通过SSL进行通信,但当我使用我的Java消费 ..

如何在动态环境中设置Kafka Security和侦听器?

这些资源很好地介绍了如何设置kafka安全性(加密+ ssl)以及kafka侦听器的好主意. 设置ssl身份验证 收听者和广告收听者: a , b , d (来自合流小伙子-Robin M) 但这似乎在静态环境中很好用,而在动态环境中又如何呢? 当使用K8S和容器(在EC2等上具有k8s的docker容器)或其他编排框架时,主机名和副本数(即使没有自动缩放方案)也事先未知. 因此, ..