Kafka环境搭建与相关启动命令

一、Kafka环境搭建

点击下载kafka_2.11-2.3.1.tgz文件链接

1、上传kafka_2.11-2.3.1.tgz,解压kafka_2.11-2.3.1.tgz,得到kafka_2.11-2.3.1文件夹

1)上传

#使用mobaxterm将 kafka_2.11-2.3.1.tgz 传入tools文件夹
#用下面代码进入tools文件夹

cd /tools

#查看传入成功没

ll
2)解压到training文件夹
tar -zxvf kafka_2.11-2.3.1.tgz -C /training
cd /training

2、 kafka需要安装zookeeper使用,但kafka集成zookeeper,在单机搭建时可直接使用。使用需配置kafka_2.11-2.3.1/config 下的“zookeeper.properties”

cd kafka_2.11-2.3.1/config

在这里插入图片描述

3、配置"zookeeper.properties"。修改dataDir和clientPort。前者是快照存放地址(自己随意配置),后者是客户端连接zookeeper服务的端口。默认端口2181 最好默认不修改

1)进入zookeeper.properties配置
vi zookeeper.properties

在这里插入图片描述

2)配置内容,修改dataDir和clientPort。前者是快照存放地址(自己随意配置可以和我一样),后者是客户端连接zookeeper服务的端口。默认端口2181 最好默认不修改

在这里插入图片描述

4、配置kafka_2.11-2.3.1/config下的“server.properties”,修改log.dirs和zookeeper.connect。前者是日志存放文件夹,后者是zookeeper连接地址(端口和clientPort保持一致)

vi server.properties
1)找 ### Log Basics ### 添加如图所示

在这里插入图片描述

log.dirs=/training/kafka_2.11-2.3.1/logs
2)找 ### Zookeeper ### 添加如图所示,注意修改主机名

#查询主机名我的主机名字是niit:

hostname

在这里插入图片描述
#配置截图

在这里插入图片描述

zookeeper.connect=niit:2181
listeners=PLAINTEXT://niit:9092
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
num.partitions=3
num.recovery.threads.per.data.dir=1
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1
log.retention.hours=168
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
zookeeper.connection.timeout.ms=6000
group.initial.rebalance.delay.ms=0
auto.create.topics.enable=true
delete.topics.enable=true

到此,kafka的单机环境就搭建成功了。

二、kafka的相关命令

1、开启kafka自带zookeeper

1)窗口1
cd /training/kafka_2.11-2.3.1/
./bin/zookeeper-server-start.sh ./config/zookeeper.properties

在这里插入图片描述

2)窗口2
cd /training/kafka_2.11-2.3.1/
./bin/zookeeper-server-start.sh -daemon ./config/zookeeper.properties

在这里插入图片描述
在这里插入图片描述

2、开启kafka

1)窗口2
cd /training/kafka_2.11-2.3.1/
./bin/kafka-server-start.sh ./config/server.properties

在这里插入图片描述

2)窗口3
cd /training/kafka_2.11-2.3.1/
./bin/kafka-server-start.sh -daemon ./config/server.properties

在这里插入图片描述
使用jps命令查看进程。安装配置完毕。
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/63168.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Python -【Socket select】基本使用介绍

一. 前言 在Python中,select 是一个用于异步I/O多路复用的模块。它提供了一种简单的方法,用于监视多个文件描述符(file descriptor),以确定其中哪些文件描述符已经就绪可读、可写或者发生了异常。使用 select 模块可以…

SPSS统计作图教程:频率多边形

SPSS统计作图教程:频率多边形 1、问题与数据 某研究者想了解某数据集中最大携氧能力(VO2max)是否服从正态分布,部分数据如图1。研究者应如何绘图查看呢? 图1 部分数据 2、对问题的分析 研究者想绘图展示最大携氧能…

深入理解 JVM 之——Java 内存区域与溢出异常

更好的阅读体验 \huge{\color{red}{更好的阅读体验}} 更好的阅读体验 本篇为深入理解 Java 虚拟机第二章内容,推荐在学习前先掌握基础的 Linux 操作、编译原理、计算机组成原理等计算机基础以及扎实的 C/C 功底。 该系列的 GitHub 仓库:https://github…

go学习part20(1)反射

283_尚硅谷_反射基本介绍和示意图_哔哩哔哩_bilibili 1.介绍 1)基本数据类型的类型和类别一致,但是结构体等不一样。 2)反射的例子(桥连接,序列化) 序列化指定tag,会反射生成tag字符串 3)refl…

Vue在表格中拿到该行信息的方式(作用域插槽-#default-scope-解决按钮与行点击的顺序问题)

遇到的问题 在做表格的时候,表格是封装好了的,用于展示数据。如果想给单行增加按钮,可以单独写一列存放按钮,最基本的需求是,点击按钮后要拿到数据然后发起请求。 且Vue的element-plus,当我们点击按钮之后…

Linux挖矿程序清除

1. 找到挖矿进程 2.找到病毒的文件地址 ls -l /proc/进程ID/exe3.删除文件命令 rm -rf 文件地址4.杀死挖矿进程 kill -9 进程ID

11 mysql float/double/decimal 的数据存储

前言 这里主要是 由于之前的一个 datetime 存储的时间 导致的问题的衍生出来的探究 探究的主要内容为 int 类类型的存储, 浮点类类型的存储, char 类类型的存储, blob 类类型的存储, enum/json/set/bit 类类型的存储 本文主要 的相关内容是 float, decimal 类类型的相关数据…

15. 卡牌游戏

目录 题目 思路 C整体代码(含详细注释) 题目 Description 小张在玩一种卡牌游戏,牌组由张牌组成,其中张上写有数字各一张,其余张上全部是数字。 现在牌组经过随机打乱后,小张拿走其中张牌作为手牌&#…

【方案】基于视频与AI智能分析技术的城市轨道交通视频监控建设方案

一、背景分析 地铁作为重要的公共场所交通枢纽,流动性非常高、人员大量聚集,轨道交通需要利用视频监控系统来实现全程、全方位的安全防范,这也是保证地铁行车组织和安全的重要手段。调度员和车站值班员通过系统监管列车运行、客流情况、变电…

【Java List与数组】List<T>数组和数组List<T>的区别(124)

List数组:存储List的数组,即:数组中的元素是:List; 数组List:存储数组的List,即:List中的数据是类型的数组; 测试案例: import java.util.ArrayList; impor…

中国建筑出版传媒许少辉博士八一新书乡村振兴战略下传统村落文化旅游设计日京东当当畅销榜自由营九三学

中国建筑出版传媒许少辉博士八一新书乡村振兴战略下传统村落文化旅游设计日京东当当畅销榜自由营九三学

【JavaSE】String类

两种创建String对象的区别 String s1 "hello"; String s2 new String("hello");s1是先查看常量池是否有 “hello” 数据空间,如果有就直接指向它,如果没有就创建然后指向它。s1最终指向的是常量池的空间地址。 s2是先在堆中创建空…

MySQL数据库——多表查询(3)-自连接、联合查询、子查询

目录 自连接 查询语法 自连接演示 联合查询 查询语法 子查询 介绍 标量子查询 列子查询 行子查询 表子查询 自连接 通过前面的学习,我们对于连接已经有了一定的理解。而自连接,通俗地去理解就是自己连接自己,即一张表查询多次。…

XSS攻击

目录 什么是XSS脚本攻击XSS攻击的本质XSS 攻击分类存储型 XSS 的攻击步骤:反射型 XSS 的攻击步骤:DOM 型 XSS 的攻击步骤: 前端处理后端处理参考资料 随着互联网的高速发展 信息安全问题已经成为企业最为关注的焦点之一,而前端又…

【electron】Puppeteer 和 Electron 共用同一个Chrome 或 Chromium浏览器二进制文件

将 Puppeteer 的可执行路径设置为 Electron 的可执行路径来实现这一点 以下是一个示例代码,展示了如何在 Puppeteer 中使用 Electron 的浏览器二进制文件: const puppeteer require(puppeteer-core);(async () > {// 设置 Electron 的可执行路径co…

visual studio编写DLL,python调用

选择第一个c DLL&#xff0c; 然后项目源文件下右击新建项&#xff0c;这里名字随便取&#xff0c;在代码中输入一下内容&#xff1a; #include <iostream>#define EXPORT extern "C" __declspec(dllexport)EXPORT int sub(int a, int b) {return a - b; } 在…

SpringBoot项目配置文件数据库用户名密码加密

1、需求 在使用SpringBoot开发过程中&#xff0c;会将一些敏感信息配置到SpringBoot项目的配置文件中(不考虑使用配置中心的情况 )&#xff0c;例如数据库的用户名和密码、Redis的密码等。为了保证敏感信息的安全&#xff0c;我们需要将此类数据进行加密配置。 2、操作步骤 …

Vue 纯 css 编写鱼骨图

Vue 纯 css 编写鱼骨图 参考文章1忘记 参考文章1会点 php 的前端小渣渣 &#xff08;我是在此基础上进行二改的&#xff09; 二改组件 粘贴下来到手直接用。 <template><div class"fishbone scroll"><div class"content"><el-row typ…

网络编程套接字(3): 简单的TCP网络程序

文章目录 网络编程套接字(3)4. 简单的TCP网络程序4.1 服务端创建(1) 创建套接字(2) 绑定端口(3) 监听(4) 获取新连接(5) 处理读取与写入 4.2 客户端创建(1)连接服务器 4.3 代码编写(1) v1__简单发送消息(2) v2_多进程版本(3) v3_多线程版本(4) v4_线程池版本 网络编程套接字(3)…

leetcode原题: 生存人数

题目&#xff1a; 给定 N 个人的出生年份和死亡年份&#xff0c;第 i 个人的出生年份为 birth[i]&#xff0c;死亡年份为 death[i]&#xff0c;实现一个方法以计算生存人数最多的年份。 你可以假设所有人都出生于 1900 年至 2000 年&#xff08;含 1900 和 2000 &#xff09;…