WSL2 Ubuntu安装Kafka教程
简介
在WSL Ubuntu上安装Kafka,并配置宿主机访问。在安装Kafka之前,务必配置好JDK。
安装
首先访问官网下载合适版本的源码(建议下载推荐版本),通过如下命令下载并解压(我这里先是切换到了习惯安装软件的目录)。
cd ~/opt/
wget https://www.apache.org/dyn/closer.cgi?path=/kafka/3.2.0/kafka_2.13-3.2.0.tgz
tar -zxvf kafka_2.13-3.2.0.tgz
cd kafka_2.13-3.2.0/
为了保证宿主机的访问,我们需要修改一下Kafka-server的配置文件( vim config/server.properties
),需要将下面两项解除注释并改为如下内容。
listeners = PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://localhost:9092
至此,安装结束。
启动
在Kafka的安装目录下,我们首先在后台开启zookeeper服务,具体命令如下。
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
然后启动kafka-server,命令如下,此时这个终端就成了一个后台监控,不能关闭否则会终止kafka服务。(当然我们还是可以选择类似上面的方式处理为后台守护进程,但是这里为了演示不这么干。)
bin/kafka-server-start.sh config/server.properties
主题创建
新开一个终端并切换到kafka安装目录下,使用 kafka-topics.sh
创建单分区单副本的主题testing
,命令如下:
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic testing
成功创建后,终端会输出Created topic testing.
。
我们可以通过kafka-topics.sh
命令来查看当前所有的主题列表,具体如下,应该可以看到testing。
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
消息处理
我们可以先进行简单的模拟看看Kafka在当前环境内(WSL)是否可以正常工作,再尝试宿主机访问能否成功。打开两个终端,均切换到kafka安装目录中的bin
文件夹下,一个用来做生产者,一个用来做消费者。
首先,在第一个终端,我们通过生产者命令向指定服务器的指定主题发布消息,会打开一个交互式的输入,我们输入几个测试数据,如下图。
./kafka-console-producer.sh --broker-list localhost:9092 --topic testing
然后,在另一个终端通过消费者命令读取主题的消息,显然,当发送新的消息,它立刻能收到,如下图。
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testing --from-beginning
Spring集成
保证上面的zookeeper和kafka的服务不关闭,我们利用Spring来访问Kafaka,首先需要安装spring-kafka
依赖包,然后配置application.properties
增加如下内容。
# KafkaProperties
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=test-consumer-group
spring.kafka.consumer.enable-auto-commit=true
spring.kafka.consumer.auto-commit-interval=3000
然后,编写如下的测试代码,模拟一个生产者发送两条消息,消费者订阅tesing
主题,得到消息则输出。
package com.zc.community;import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;
import org.springframework.test.context.ContextConfiguration;@SpringBootTest
@ContextConfiguration(classes = CommunityApplication.class)
public class KafkaTests {@Autowiredprivate KafkaProducer kafkaProducer;@Testpublic void testKafka(){kafkaProducer.sendMessage("testing", "wo shi zc");kafkaProducer.sendMessage("testing", "nihao");try {Thread.sleep(1000 * 10);} catch (InterruptedException e){e.printStackTrace();}}
}@Component
class KafkaProducer{@Autowiredprivate KafkaTemplate kafkaTemplate;public void sendMessage(String topic, String content){System.out.println("生产者发送消息:" + content);kafkaTemplate.send(topic, content);}
}@Component
class KafkaConsumer {@KafkaListener(topics = {"testing"})public void handleMessage(ConsumerRecord record){System.out.println("消费者收到消息:" + record.value());}
}
得到的依次输出如下。
生产者发送消息:wo shi zc
生产者发送消息:nihao
消费者收到消息:wo shi zc
消费者收到消息:nihao
这代表Kafka正常运行,并且宿主机可以通过Spring集成对齐进行操作。
总结
简单介绍在WSL中Kafka的安装和使用。
WSL2 Ubuntu安装Kafka教程相关推荐
- (一)Ubuntu安装详细教程(从镜像制作到NVIDIA驱动安装全流程)——超详细的图文教程
Ubuntu安装详细教程(从下载镜像到安装NVIDIA驱动) 1.下载镜像文件 2.制作硬盘镜像 2.1 安装UltraISO并打开ISO文件 2.2 制作硬盘镜像 2.3 检查是否成功 3.划分磁盘 ...
- ubuntu篇---ubuntu安装mysql教程
ubuntu篇---ubuntu安装mysql教程 一. 首先卸载掉原来的mysql 第一步,依次执行下面的语句 第2步 清理残留数据 第三步 验证原有主机上是否安装mysql: 二. 安装mysql ...
- 大数据——VMware Ubuntu安装详细教程
VMware Ubuntu安装详细教程 下载Ubuntu镜像文件 VMware安装Ubuntu 下载Ubuntu镜像文件 下载地址:Ubuntu 打开下载链接,点击download 下一步,点击Ubu ...
- Ubuntu安装微信教程 超简单的
Ubuntu安装微信教程 超简单的[5P] 这次我用的系统是Ubuntu 16.04 x86,在网上先去下载electronic-wechat-linux https://github.com/gee ...
- docker安装kafka教程
docker安装kafka教程:https://blog.csdn.net/lw1124052197/article/details/103781350 注意:kafka玄幻发消息时得设置一个延迟,否 ...
- Ubuntu 安装OBS教程
Ubuntu 安装OBS教程 注:本教程使用的Ubuntu版本为20.04 1. 使用apt-get命令安装: sudo apt install ffmpeg 需要先安装一个ffmpeg依赖 2. 安 ...
- Ubuntu安装Qt教程
ubuntu部署Qt教程 在中写了Qt开发需要的三样东西,这里就不讲了
- ubuntu安装nginx教程
Ubuntu是一个基于Debian的Linux操作系统,承诺将永远免费,包括企业版和安全升级.下面介绍Ubuntu安装Nginx的方法,希望能有所帮助. 工具/原料 Ubuntu Server 18. ...
- Ubuntu 安装 PostgreSQL 教程
Ubuntu 安装 PostgreSQL 使用 apt-get 安装 PostgreSQL: sudo apt-get update sudo apt-get install postgresql p ...
最新文章
- cmd for 循环拷贝文件
- mysql 开启不严谨模式,mysql – 为什么innodb严格模式无法启用?
- Eclipse反编译工具Jad及插件JadClipse配置
- 白话 Python 的函数式编程
- eclipse手动pom本地包_环境篇--Eclipse如何远程连接Hadoop集群调试
- Linux学习笔记033_8文本处理
- SAP Cloud Application Studio避免出现性能问题的一些最佳实践
- android中的ContentProvider实现数据共享
- java 存储png文件_vue图片上传及java存储图片(亲测可用)
- 送书 | 222Beta多样性限制性排序CPCoA/CCA/RDA/LDA
- DBeaver 导出EXCEL文件
- python自带的对称算法_一种基于对称算法和专用加载模块的Python程序模块加密方法...
- 在JavaScript里 (a ==1 a== 2 a==3) 有可能是 true 吗?
- SQL Server IF Exists 判断数据库对象是否存在的用法
- cmd cd命令_Windows系统CMD命令提示符的常用命令汇总
- IDL | 实验四 IDL输入输出
- ai/ml_您应该在本周(7月11日)阅读有趣的AI / ML文章
- 【人工智能】机器学习:岭回归与LASSO回归(Ridge/LASSO Regression)
- vnc连接linux使用教程_远程管理之VNC 详解
- Linux系统中常用命令行命令、快捷键、创建长路径的快捷键
热门文章
- css设置字体大小等失效
- html语言怎么改变文字大小,如何设置css中字体大小?
- CUDA和OpenCL比较
- 为什么C++20中要移除std::alloctor的construct与destory
- css实现三角的一些方法
- 什么是算数运算c语言,第二种是C语言的算术运算.ppt
- react native TextInput输入限制字数长度在安卓和iOS设备上部分系统键盘输入问题
- Linux设备驱动之——I2C总线
- 【ZYNQ】IP核_VDMA的详细介绍
- Zynq-PS-SDK(13) 之 VDMA+VTC+AXI4S-VideoOut 视频通路软件配置