1.創(chuàng)建安裝目錄/usr/local/kafka
mkdir /usr/local/kafka
2.進(jìn)入安裝包目錄
cd?/usr/local/kafka?
3.下載安裝包
wget https://downloads.apache.org/kafka/3.3.1/kafka_2.12-3.3.1.tgz
4.解壓安裝包
tar -zxvf kafka_2.12-3.3.1.tgz
5.進(jìn)入cd kafka_2.12-3.3.1目錄
cd kafka_2.12-3.3.1/
6.修改zookeeper配置
cat ./config/zookeeper.properties | grep -v '#' >> ./config/zk.properties
7.啟動zookeeper
bin/zookeeper-server-start.sh config/zk.properties &
8.修改kafka配置
cat ./config/server.properties | grep -v '#' >> ./config/ka.properties
9.啟動kafka
bin/kafka-server-start.sh config/server.properties &
10.創(chuàng)建topic
bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --partitions 2 --replication-factor 1 --topic test
?文章來源地址http://www.zghlxwxcb.cn/news/detail-416094.html
11.創(chuàng)建生產(chǎn)者，啟動producer
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
12.創(chuàng)建消費(fèi)者，啟動consumer
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
文章來源：http://www.zghlxwxcb.cn/news/detail-416094.html
?
到了這里，關(guān)于Linux安裝Kafka，創(chuàng)建topic、生產(chǎn)者、消費(fèi)者的文章就介紹完了。如果您還想了解更多內(nèi)容，請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
