Kafka 简介及相关组件介绍
伪集群模式
Kafka伪集群是一种在单个机器上模拟多节点Kafka集群的配置方式，主要用于开发和测试环境。在伪集群模式下，你可以配置多个Kafka broker实例，它们都连接到同一个Zookeeper实例或者集群，从而模仿分布式环境下的行为，而无需实际部署多台物理或虚拟机。
如何搭建Kafka伪集群：
准备环境：
确保你的机器上已安装Java环境，因为Kafka运行需要Java支持。
下载Kafka的发行包，可以选择包含Zookeeper的版本，或者单独下载Zookeeper，根据需要解压。
配置Zookeeper：
如果Kafka包内包含Zookeeper，你可能需要为Zookeeper创建多个数据目录，比如
/path/to/zookeeper/data/server0、/path/to/zookeeper/data/server1等，对应不同的Zookeeper实例（尽管在伪集群模式下，这些实例仍运行在同一台机器上）。修改Zookeeper的配置文件（如
zookeeper.properties），为每个实例配置不同的客户端端口（如clientPort=2181,clientPort=2182, ...）和数据目录。
配置Kafka Broker：
进入Kafka解压目录，复制
config/server.properties文件多次，分别代表不同的broker，比如server.properties、server-1.properties、server-2.properties等。在每个配置文件中修改以下参数以区分不同的broker：
broker.id: 设置唯一的broker ID，如0、1、2等。listeners: 配置监听地址和端口，确保每个 broker 的端口不冲突。log.dirs: 可以指定不同的日志目录，以便于区分不同 broker 的日志。zookeeper.connect: 指向你的 Zookeeper 实例地址，如果是单机伪集群，可能是localhost:2181,localhost:2182,localhost:2183这样的格式。
启动每个 Kafka broker，通常是通过运行脚本
bin/kafka-server-start.sh config/server.properties，使用对应的配置文件。
验证伪集群：
使用Kafka的命令行工具创建主题、发送消息和消费消息，验证消息是否能在各个broker之间正确生产和消费。
观察日志输出，确认所有 broker 和 Zookeeper 正常运行并且彼此间通讯无误。
通过上述步骤，你就可以在单台机器上模拟出一个Kafka分布式环境，这对于开发测试非常有用，避免了在多台机器上部署的复杂性和资源消耗。不过，请注意，伪集群虽然在功能上模拟了分布式环境，但它无法完全模拟出真实集群中的网络延迟、负载均衡等问题，因此在性能和稳定性测试方面可能有所局限。
示例演示