如何安裝Kafka

這篇文章主要為大家展示了“如何安裝Kafka”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“如何安裝Kafka”這篇文章吧。

首先安裝Docker,Docker為Windows、Mac都提供了安裝包 Docker Desktop. 安裝即可用，這個包涵了多個docker組件，包括 docker compose、docker swarm、docker-machine。

1)、安裝Docker Desktop

2)、拉取ubuntu系統(tǒng)，作為實驗的操作系統(tǒng)

Docker pull ubuntu

3)、啟動ubuntu系統(tǒng)，并進(jìn)入

Docker run -it  --name kafka  ubuntu bash   進(jìn)入

4)、下載kafka安裝包

下載Kafka 

https://www.apache.org/dyn/closer.cgi?path=/kafka/2.3.0/kafka_2.11-2.3.0.tgz

將kafka拷貝到docker ubuntu 容器中

docker cp kafka_2.11-2.3.0.tgz  kafka:/usr/local/kafka

tar -zxvf kafka_2.11-2.3.0.tgz  

5)、配置JDK環(huán)境

下載JDK1.8 并拷貝到kafka容器中，并配置

6)、啟動Kafka自帶Zookeeper服務(wù)

啟動ZK

bin/zookeeper-server-start.sh config/zookeeper.properties

7)、啟動Kakfa環(huán)境

啟動kafka    

bin/kafka-server-start.sh config/server.properties

8)、創(chuàng)建topic 指定副本以及分區(qū)個數(shù)

另外啟動控制臺，通過docker exec -it kafka bash 進(jìn)入容器中，創(chuàng)建一個topic z指定副本數(shù)為1，分區(qū)數(shù)為1，topic為test

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

9)、啟動生產(chǎn)者Demo

開啟kafka生產(chǎn)者進(jìn)程，輸入hello kafka

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

10)、啟動消費者Demo

啟動kafka消費者進(jìn)程

以上是“如何安裝Kafka”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注億速云行業(yè)資訊頻道！