![Kafka进阶](https://wfqqreader-1252317822.image.myqcloud.com/cover/408/43738408/b_43738408.jpg)
上QQ阅读APP看本书,新人免费读10天
设备和账号都新为新人
2.2.1 单机单Broker的部署
如图2.8所示,在单机单Broker的模式下,在kafka101的虚拟主机上部署一个Broker用于接收和转发生产者发布的消息。在这种模式下,由于只存在一个Broker,将存在单点故障的问题,即Broker本身或Broker所在的主机宕机后,都会造成Kafka无法正常工作,所以这种模式只能用于开发和测试环境。
![](https://epubservercos.yuewen.com/527ABA/23020654009771406/epubprivate/OEBPS/Images/42653-00-052-01.jpg?sign=1739443147-i1TeSadCEcdz9ojuZyEm1ib7Fr49QSkq-0-8136e5a5fc2a39ad8457415b61be7b29)
图2.8 Kafka单机单Broker模式
首先,将压缩包解压至/root/training目录。
![](https://epubservercos.yuewen.com/527ABA/23020654009771406/epubprivate/OEBPS/Images/42653-00-052-2.jpg?sign=1739443147-MUI5SbapnaK5VUVwbIowxY1aiev9B0B0-0-8f2d9b95836832e4233ae840b1d2f447)
进入Kafka的config目录,并修改server.properties文件。
![](https://epubservercos.yuewen.com/527ABA/23020654009771406/epubprivate/OEBPS/Images/42653-00-052-3.jpg?sign=1739443147-0ipE2rZjltatVe4kAJZNscHqgn7reUSq-0-1881d71b68614330ee7cca72e125ecf9)
下面列出了需要修改的参数。
![](https://epubservercos.yuewen.com/527ABA/23020654009771406/epubprivate/OEBPS/Images/42653-00-053-1.jpg?sign=1739443147-Gpyykv9wcc4HFRlmf09DsamZQmqnA6BQ-0-b2f2756907d72ea6ee241c1e2e3747ce)
其中,
• broker.id表示broker的id号。在一个Kafka集群中,不同的Broker应该具有不同的id号,不能重复。
• log.dirs表示Kafka日志数据的存放地址,多个地址用逗号分隔。这里我们为了方便管理,为每个Broker单独创建一个目录来存储这个Broker所对应的日志数据。
• zookeeper.connect表示连接ZooKeeper进群的地址。
关于这些Kafka配置参数的详细说明,我们会在后续章节中进行介绍。
创建Broker 0日志存储的目录。
![](https://epubservercos.yuewen.com/527ABA/23020654009771406/epubprivate/OEBPS/Images/42653-00-053-2.jpg?sign=1739443147-ckzcgc4uvLNnvmKhVqIZS3tQL3cvdWm0-0-f237bcd36c871731fff0c821acf7fc5d)
启动Kafka Broker。
![](https://epubservercos.yuewen.com/527ABA/23020654009771406/epubprivate/OEBPS/Images/42653-00-053-3.jpg?sign=1739443147-NKaFg1fo675DeHg366i4hWBsxW4XJSGP-0-789ccc7ea81d4dd11a8caa2bf707637f)
启动成功后,将输出如下日志信息,如图2.9所示。
![](https://epubservercos.yuewen.com/527ABA/23020654009771406/epubprivate/OEBPS/Images/42653-00-053-01.jpg?sign=1739443147-041RjMiF0cFql5Z3pmj0p3e0MOVZvTPM-0-38a4efbabc0a9db80765449a9f8ed814)
图2.9 Broker启动成功日志
也可以通过Java的jps命令查看后台的Java进程,如图2.10所示。
![](https://epubservercos.yuewen.com/527ABA/23020654009771406/epubprivate/OEBPS/Images/42653-00-053-02.jpg?sign=1739443147-sRTZootFKDXhfSAyGWCiGG9zP5F1P4k8-0-2ec3eb51c220383c9322c1f86fd20518)
图2.10 Kafka的后台进程信息
其中44272进程就是Kafka Broker对应的进程,而43579进程就是我们前面配置好的ZooKeeper进程。