消息队列作为服务解耦、异步收发消息的组件，如今已经广泛应用于各大互联网公司，具备一定规模的公司会有专门的团队负责维护消息队列。当我们需要使用消息队列时，得写专门的代码进行连接，比如若用Golang编码，当需要使用Kafk...

联系OP同学申请机器，Linux服务器一台、三台、五台、（2*n+1），Zookeeper集群的工作是超过半数才能对外提供服务，3台中超过两台超过半数，允许1台挂掉 ，是否可用偶数，其实没必要。如果有四台那么挂掉一台还剩下三台服务器，如果在挂...

1、 Kafka的安装需要java环境，cent os 7自带java1.6版本，可以不用重新安装，直接使用自带的jdk 即可；如果觉得jdk版本太旧，也可以自己重新安装；

Windows系统是建立在事件驱动的机制上的，整个系统都是通过消息传递来实现的。而钩子是Windows系统中非常重要的系统接口，用它可以截获并处理送给其他应用程序的消息，来完成普通应用程序难以实现的功能。钩子可以监视系统...

在#192.168.1.128服务器上生产者控制台输入：hello kafka进行测试

1.上传解压 2.修改配置文件 3.分发到其他节点下 4.启动 5.测试 6.注意

advertised_listeners 监听器会注册在 zookeeper 中；

Kafka 使用 Zookeeper 来维护集群成员的信息。每个 broker 都有一个唯一标识符，这个标识符可以在配置文件里指定，也可以自动生成。在 broker 启动的时候，它通过创建临时节点把自己的 ID 注册到 Zookeeper。Kafka 组件订...

2.接下来，在一个机器上停止kafka,1机器上的副本全部被踢出ISR集合了

文章来源：blog.csdn.net/gu131007416553/article/details/120934738