kafka单机安装和启动

摘要:
1.下载并解压到/usr/local/src目录下2.运行kafka需要使用Zookeeper,先启动Zookeeper,如果没有Zookeeper,可以使用kafka自带打包和配置好的Zookeeper前台运行:bin/zookeeper-server-start.shconfig/zookeeper.properties后台运行:nohupbin/zookeeper-server-start.

1.下载并解压到/usr/local/src目录下
kafka单机安装和启动第1张

2.运行kafka需要使用Zookeeper,先启动Zookeeper,如果没有Zookeeper,可以使用kafka自带打包和配置好的Zookeeper

前台运行:
bin/zookeeper-server-start.sh config/zookeeper.properties

后台运行:
nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper-run.log 2>&1 &

kafka单机安装和启动第2张

3.启动kafka

前台运行:
bin/kafka-server-start.sh config/server.properties

后台运行:
nohup bin/kafka-server-start.sh config/server.properties > kafka-run.log 2>&1 &

kafka单机安装和启动第3张

4.创建topic

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

显示kafka topic:
bin/kafka-topics.sh -list -zookeeper  localhost:2181

5.创建生产者和消费者

创建kafka生产者:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

创建kafka消费者:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

设置kafka消费组名:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --consumer-property group.id=test-group

kafka单机安装和启动第4张
kafka单机安装和启动第5张

免责声明:文章转载自《kafka单机安装和启动》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇spring boot tomcat 打本地包成war,通过Tomcat启动时出现问题: ZipException: error in opening zip file代理ARP的总结下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

修改python默认版本

查看默认Python版本 python -V 1、安装gcc,用于编译Python源码 yum install gcc 2、下载源码包,https://www.python.org/ftp/python/ 3、解压并进入源码文件 4、编译安装 ./configure make all make install 5、查看版本...

vue中使用ueditor富文本编辑框

1.把下载的Ueditor资源,放入静态资源static中。 修改ueditor.config.js中的window.UEDITOR_HOME_URL配置,如下图: 2.在main.js中引入以下文件: import '../static/UE/ueditor.config.js'import '../static/UE/ueditor.all.min...

如何用nodejs 开发一个命令行交互工具

参考地址1 参考地址2 一、npm package.json bin 1、package.json { "name": "test", "version": "1.0.0", "description": "", "main": "index.js", "scripts": { "test": "echo "Erro...

AWS S3 JAVASCRIPT SDK 上传

<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>Document</title> <!-- <script src="https://sdk.amazona...

Huawei-R&amp;amp;S-网络工程师实验笔记20190607-STP生成树协议(基本配置、桥优先级、根桥选举、根端口、路径开销、边缘端口)

》Huawei-R&S-网络工程师实验笔记20190607-STP生成树协议(基本配置、桥优先级、根桥选举、根端口、路径开销、边缘端口) 》》实验开始,先上拓扑图参考: <Huawei>system-view Enter system view, return user view with Ctrl+Z. [Huawei]sysna...

报错 Invalid options in vue.config.js: "baseUrl" is not allowed 问题解决

报错 Invalid options in vue.config.js: "baseUrl" is not allowed vue3.0版本中 执行 npm run build会出现报错 Invalid options in vue.config.js: "baseUrl" is not allowed 这是因为vue cli3.3之后废除了baseUr...