1.下載kafka的 沒有的可以到我百度網盤下載

2.下載的文件上傳至linux系統下面新建在根目錄新建個文件夾下面（JDK別忘記安裝）

cd / --進入根目錄 mkdir kafka --創建kafka目錄 cd kafka --進入kafka目錄

3.解壓kafka文件

tar -zxf kafka_2.11-2.0.0.tgz --解壓安裝

4.進入目錄下面新建 zookeeper 數據存放目錄（如果外部zookeeper可以忽略本步驟）和創建kafka日志文件目錄

mkdir zdata --創建zookeeper存放數據目錄 mkdir logs --創建kafka日志存放目錄

5.修改zookeeper配置文件信息

cd kafka_2.11-2.0.0/config/ --進入目錄 vim zookeeper.properties --修改配置文件信息

紅框中改成步驟4所創建的目錄路徑

6.修改kafka配置文件

vim server.properties

log.dirs=/kafka/logs 日志存放路徑
port=9092 端口
host.name=192.168.163.131 IP地址

zookeeper.connect=localhost:2181 zookeeper的地址本機的就localhost 其他服務器的用IP加端口就可以了

7.啟動zookeeper服務

cd kafka_2.11-2.0.0/ --進入目錄 bin/zookeeper-server-start.sh config/zookeeper.properties --啟動服務

8.啟動kafka服務

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

9.下面就是創建topic? 名為test

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test

10.啟動生產主體

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

寫內容回車就可以發送信息了。

?

好了上面安裝講完了，下面開始說下消費者項目搭建

項目采用的是springboot

1.在pom.xml加入引用

<dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId></dependency>

2.在application.yml 文件中加上

spring:kafka:consumer:enable-auto-commit: truegroup-id: applogauto-offset-reset: latestbootstrap-servers: 192.168.163.131:9092 //kafka的地址

3.創建個監聽類

package com.netintech.kafka.utils; import com.netintech.kafka.bean.Test; import com.netintech.kafka.mapper.TestRepository; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.kafka.annotation.KafkaListener; import org.springframework.stereotype.Component;@Component public class Listener {protected final Logger logger = LoggerFactory.getLogger(this.getClass());@KafkaListener(topics = {"test"})public void receive(String message){System.out.println("test1--消費消息:" + message);}}

啟動項目開始測試?

在服務器使用生產者發送消息

總結

以上是生活随笔為你收集整理的kafka在linux下安装教程及其消费者项目开发搭建教程的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。