首先，ZooKeeper 提供了分布式数据的发布/订阅功能。这让我想到一种模式，观察者模式：一个典型的发布/订阅模型系统定义了一种一对多的订阅关系，能够让多个订阅者同时监听某一个主题对象，当这个主题自身状态变化时，会通知所有订阅者，试它们能够做出相应的处理。那 ZooKeeper 是不是也是使用了这个经典的模式呢？在 ZooKeeper 中，引入了 Watcher 机制来实现这种分布式的通知功能。

参考：https://kafka.apache.org/documentation/#security单向认证首先实现单向的认证，即，client 对 broker 的认证。就像浏览器对服务器的认证一样。注：密钥生成过程中的密码统一为test123。为broke生成keystore第一步是为集群的每台机器生成密钥和证书，可以使用java的keytool来生产。我们将生成密钥

背景首先，用户数据会经过 kafka 队列传递到我们的业务层。我们希望用户能够通过一个通用层接入我们的kafka服务，但是有的用户希望能够直接连到我们的 kafka 上面，这就需要我们的 kafka 对外暴露broke服务以便被接入。那么如何保证用户数据接入的可靠性和安全性，就成为了这篇文章的主要内容。目标我们希望其他公司数据接入的方式尽量松耦合，尽量不依赖内部架构，而对于一些用户要直

系统：centos7下载kafka：http://kafka.apache.org/downloads ，我下载的版本为 kafka_2.11-0.10.1.0.tgz 。安装ZooKeeper，默认已经安装好 zookeeper-3.4.9 并已经启动。第1步，下载解压 kafka：# tar -xzf kafka_2.11-0.10.1.0.tgz# cd kafka_