Kafka單機安裝教程
在進行Kafka的單機安裝之前,首先需要下載Kafka安裝包并將其解壓到指定路徑。你可以從Kafka官網(wǎng)上下載kafka_,并將其復制到虛擬機Ubuntu22.1中。接著,在命令行中執(zhí)行以下操作來解壓
在進行Kafka的單機安裝之前,首先需要下載Kafka安裝包并將其解壓到指定路徑。你可以從Kafka官網(wǎng)上下載kafka_,并將其復制到虛擬機Ubuntu22.1中。接著,在命令行中執(zhí)行以下操作來解壓安裝包和將文件移動到指定目錄:
```shell
tar zxvf kafka_
sudo mv kafka /home/chen-pc/kafka
```
啟動和停止Kafka服務
要啟動Zookeeper服務器,可以在命令行中輸入以下代碼:
```shell
```
而停止Kafka服務器則需要執(zhí)行如下命令:
```shell
```
當出現(xiàn)類似以下信息時,表示Kafka服務器已經(jīng)成功關閉:
```
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)建啟動、關閉Kafka腳本
在Kafka安裝目錄下創(chuàng)建啟動和關閉Kafka的腳本是一個很好的習慣。你可以按照以下步驟創(chuàng)建這些腳本并添加相應的代碼,以便于后續(xù)的操作:
```shell
vi
vi
chmod x
chmod x
```
通過以上步驟,你就可以使用``啟動Kafka服務,使用``關閉Kafka服務。這樣可以更加方便地管理Kafka的啟動和停止。
Kafka創(chuàng)建topic和刪除topic
在Kafka中,你可以創(chuàng)建topic來存儲消息,并且也可以隨時刪除不再需要的topic。通過以下命令,你可以輕松完成這些任務:
```shell
--create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
--delete --zookeeper localhost:2181 --topic test
```
同時,你也可以通過以下命令查看當前存在的所有topic:
```shell
--list --zookeeper localhost:2181
```
啟動consumer和producer
最后,你可以啟動Kafka的consumer和producer,以便在系統(tǒng)中傳遞消息。在啟動producer后的console輸入一些信息后,可以使用以下命令啟動consumer來獲取這些信息:
```shell
--broker-list localhost:9092 --topic test
--zookeeper localhost:2181 --topic test --from-beginning
```
通過以上步驟,你已經(jīng)成功地部署了Kafka并進行了相關配置,愿你在使用Kafka的過程中能夠順利完成各項操作!