上QQ阅读APP看本书,新人免费读10天
设备和账号都新为新人
2.2.1 单机单Broker的部署
如图2.8所示,在单机单Broker的模式下,在kafka101的虚拟主机上部署一个Broker用于接收和转发生产者发布的消息。在这种模式下,由于只存在一个Broker,将存在单点故障的问题,即Broker本身或Broker所在的主机宕机后,都会造成Kafka无法正常工作,所以这种模式只能用于开发和测试环境。
图2.8 Kafka单机单Broker模式
首先,将压缩包解压至/root/training目录。
进入Kafka的config目录,并修改server.properties文件。
下面列出了需要修改的参数。
其中,
• broker.id表示broker的id号。在一个Kafka集群中,不同的Broker应该具有不同的id号,不能重复。
• log.dirs表示Kafka日志数据的存放地址,多个地址用逗号分隔。这里我们为了方便管理,为每个Broker单独创建一个目录来存储这个Broker所对应的日志数据。
• zookeeper.connect表示连接ZooKeeper进群的地址。
关于这些Kafka配置参数的详细说明,我们会在后续章节中进行介绍。
创建Broker 0日志存储的目录。
启动Kafka Broker。
启动成功后,将输出如下日志信息,如图2.9所示。
图2.9 Broker启动成功日志
也可以通过Java的jps命令查看后台的Java进程,如图2.10所示。
图2.10 Kafka的后台进程信息
其中44272进程就是Kafka Broker对应的进程,而43579进程就是我们前面配置好的ZooKeeper进程。