江苏龙网

  1. 主页 > 生活百科 > >

一文带您快速入门Kafka( 三 )

Kafka

 接着 ， 到 /root/zookeeper-3.4.6/data 创建文件 myid（如果部署的是集群 ， 那么这个 myid 必需唯一 ， 不能重复） 。cat > myidvi myid 具体如下：

一文带您快速入门Kafka

文章插图
6.配置环境变量vi /etc/profile export ZOOKEEPER_HOME=/root/zookeeper-3.4.6export PATH=$PATH:$ZOOKEEPER_HOME/bin
一文带您快速入门Kafka

文章插图
再执行 source /etc/profile
至此 ， ZooKeeper 已经配置好了 ， 我们可以启动看下是否有问题 。2.2 安装 Kafka1.到官网下载安装包
一文带您快速入门Kafka

文章插图
2.使用 psftp 上传到服务器
一文带您快速入门Kafka

文章插图
# put dir remoteDirput D:downloadskafka_2.13-3.5.0.tgz /root/kafka_2.13-3.5.0.tgz 
一文带您快速入门Kafka

文章插图
3.解压tar -zxvf kafka_2.13-3.5.0.tgz4.修改配置 cd kafka_2.13-3.5.0cd config/ 由于 server.properties 比较大 ， 就不全部贴上来了 ， 只贴我修改的部分：# 是Broker的标识 ， 因此在集群中必需唯一broker.id=0# Broker 对外服务地址(我这里vmware的ip是192.168.226.140)listeners=PLAINTEXT://192.168.226.140:9092# 实际工作中 ， 会分内网外网 ， 当有需要提供给外部客户端使用时 ， 我们一般 listeners 配置内网供 Broker 之间通信使用 ， 而 advertised.listeners 配置走外网给接入的客户端使用#advertised.listeners=PLAINTEXT://your.host.name:9092# 存放消息日志文件地址log.dirs=/root/kafka_2.13-3.5.0/logs# ZK 的访问路径 ， 我这里因为 ZK 和 Kafka 放在了同一个服务器上 ， 所以就使用了 localhostzookeeper.connect=localhost:2181 5.修改环境变量vi /etc/profile export KAFKA_HOME=/root/kafka_2.13-3.5.0export PATH=$PATH:$KAFKA_HOME/bin再执行 source /etc/profile
6.进入bin目录 ， 启动 Brokerkafka-server-start.sh ../config/server.properties &ps -ef|grep kafka 看下进程 ， 但是是否已经可以使用 ， 要通过发送消息和消费消息来验证 。
一文带您快速入门Kafka

文章插图
3 使用 Spring Boot 实现简单的 Demo下面是示例代码：
pom.xml<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><!-- spring boot3.0+ 只支持jdk17 ， 如果使用1.8出现包冲突需要自己处理 --><version>2.7.12</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.example.czl</groupId><artifactId>kafka</artifactId><version>0.0.1-SNAPSHOT</version><name>springboot-kafka</name><description>spring boot集成kafka demo</description><properties><JAVA.version>1.8</java.version><MyBatis-plus.version>3.5.3.1</mybatis-plus.version><velocity-engine-core.version>2.3</velocity-engine-core.version><lombok.version>1.18.26</lombok.version><guava.version>31.1-jre</guava.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId></dependency><dependency><groupId>com.MySQL</groupId><artifactId>mysql-connector-j</artifactId><scope>runtime</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka-test</artifactId><scope>test</scope><exclusions><exclusion><artifactId>scala-library</artifactId><groupId>org.scala-lang</groupId></exclusion><exclusion><artifactId>scala-reflect</artifactId><groupId>org.scala-lang</groupId></exclusion></exclusions></dependency><!-- mybatis-plus --><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>${mybatis-plus.version}</version></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-generator</artifactId><version>${mybatis-plus.version}</version></dependency><dependency><groupId>org.apache.velocity</groupId><artifactId>velocity-engine-core</artifactId><version>${velocity-engine-core.version}</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>${lombok.version}</version></dependency><dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>${guava.version}</version></dependency></dependencies><!-- 对于一些特殊的依赖指定特定版本 --><!--<dependencyManagement><dependencies><dependency><groupId>org.yaml</groupId><artifactId>snakeyaml</artifactId><version>2.0</version></dependency></dependencies></dependencyManagement>--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>


推荐阅读


上一篇：一分钟告诉你国内和国外的ai绘画软件哪个好

下一篇：Flutter 地图在携程的最佳实践