在進(jìn)行Kafka的單機(jī)安裝之前，首先需要下載Kafka安裝包并將其解壓到指定路徑。你可以從Kafka官網(wǎng)上下載kafka_，并將其復(fù)制到虛擬機(jī)Ubuntu22.1中。接著，在命令行中執(zhí)行以下操作來(lái)解壓

在進(jìn)行Kafka的單機(jī)安裝之前，首先需要下載Kafka安裝包并將其解壓到指定路徑。你可以從Kafka官網(wǎng)上下載kafka_，并將其復(fù)制到虛擬機(jī)Ubuntu22.1中。接著，在命令行中執(zhí)行以下操作來(lái)解壓安裝包和將文件移動(dòng)到指定目錄：

```shell

tar zxvf kafka_

sudo mv kafka /home/chen-pc/kafka

```

啟動(dòng)和停止Kafka服務(wù)

要啟動(dòng)Zookeeper服務(wù)器，可以在命令行中輸入以下代碼：

```shell

```

而停止Kafka服務(wù)器則需要執(zhí)行如下命令：

```shell

```

當(dāng)出現(xiàn)類似以下信息時(shí)，表示Kafka服務(wù)器已經(jīng)成功關(guān)閉：

```

INFO Shutting down. (kafka.log.LogManager)

INFO Shutdown complete. (kafka.log.LogManager)

INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)

INFO Session: 0x154957ee6bc0000 closed (org.apache.zookeeper.ZooKeeper)

INFO EventThread shut down ()

INFO [Kafka Server 0], shut down completed ()

```

創(chuàng)建啟動(dòng)、關(guān)閉Kafka腳本

在Kafka安裝目錄下創(chuàng)建啟動(dòng)和關(guān)閉Kafka的腳本是一個(gè)很好的習(xí)慣。你可以按照以下步驟創(chuàng)建這些腳本并添加相應(yīng)的代碼，以便于后續(xù)的操作：

```shell

vi

vi

chmod x

chmod x

```

通過(guò)以上步驟，你就可以使用``啟動(dòng)Kafka服務(wù)，使用``關(guān)閉Kafka服務(wù)。這樣可以更加方便地管理Kafka的啟動(dòng)和停止。

Kafka創(chuàng)建topic和刪除topic

在Kafka中，你可以創(chuàng)建topic來(lái)存儲(chǔ)消息，并且也可以隨時(shí)刪除不再需要的topic。通過(guò)以下命令，你可以輕松完成這些任務(wù)：

```shell

--create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

--delete --zookeeper localhost:2181 --topic test

```

同時(shí)，你也可以通過(guò)以下命令查看當(dāng)前存在的所有topic：

```shell

--list --zookeeper localhost:2181

```

啟動(dòng)consumer和producer

最后，你可以啟動(dòng)Kafka的consumer和producer，以便在系統(tǒng)中傳遞消息。在啟動(dòng)producer后的console輸入一些信息后，可以使用以下命令啟動(dòng)consumer來(lái)獲取這些信息：

```shell

--broker-list localhost:9092 --topic test

--zookeeper localhost:2181 --topic test --from-beginning

```

通過(guò)以上步驟，你已經(jīng)成功地部署了Kafka并進(jìn)行了相關(guān)配置，愿你在使用Kafka的過(guò)程中能夠順利完成各項(xiàng)操作！