启动Kafka:kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties 创建一个叫test的话题,有两个分区,每个分区3个副本...2 查看创建的topic:kafka-topics.sh --zookeeper localhost:2181 --list 查看所有话题的详细信息:kafka-topics.sh --zookeeper...test 删除一个话题:kafka-topics.sh --zookeeper localhost:2181 --delete --topic test 生产消息:kafka-console-producer...kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1 显示所有消费者:kafka-consumer-groups.sh...--describe --group console-consumer-63307 --bootstrap-server localhost:9092 停止Kafka:kafka-server-stop.sh
--describe --zookeeper xxxx ##指定 bin/kafka-topics.sh --describe --zookeeper xxxx --topic TOPIC名称 输出...[root@ kafka]# bin/kafka-topics.sh --describe --zookeeper xxx.xx.xx.xx --topic SHI_TOPIC3 Topic:SHI_TOPIC3...--zookeeper 127.0.0.1:2181 --list ## topic列表查询(支持0.9版本+) bin/kafka-topics.sh --list --bootstrap-server...:9092 --list 输出 [root@]# bin/kafka-consumer-groups.sh --bootstrap-server xxx.xxx.xxx --list Note: This...--bootstrap-server localhost:9092 --describe --group my-group 输出 [root@dev5_172_16_10_62 kafka]# bin
/kafka-topics.sh --zookeeper 1.1.1.1:2181/kafka --alter --topic Barad_Comm --config retention.ms=43200000.../kafka-topics.sh --zookeeper 1.1.1.1:2181/kafka --alter --topic Barad_Comm --config max.message.bytes.../kafka-topics.sh --zookeeper 1.1.1.1:2181/kafka --create --topic Barad_Comm --partitions 16 --replication-factor.../kafka-topics.sh --zookeeper 1.1.1.1:2181/kafka --describe --topic Barad_Comm kafka leader 调整 kafka...自带调整工具kafka-preferred-replica-election.sh 编辑需要调整的topic 及partition ,保存为json文件。
kafka常用命令 以下是kafka常用命令行总结: 1、kafka服务启动 ./kafka-server-start.sh -daemon ...../kafka-topics.sh -zookeeper hadoop01:2181 -describe -topic test 5、kafka生产者客户端命令 ..../kafka-console-producer.sh --broker-list hadoop01:9092 --topic test 6、kafka消费者客户端命令 ..../kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic test --zookeeper hadoop01:2181 ..../kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper hadoop01:2181 --group test --topic
Broker默认端口号 9092,建议安装时,在zookeeper中指定kafka的根目录,比如“/kafka”,而不是直接使用“/”,这样多套kafka也可共享同一个zookeeper集群。...当前C++版本比较成熟,GO版本相当简略,但C++版本依赖C++运行时库,不同环境需要特定编译,而GO版本可不依赖C和C++运行时库,所以不需编译即可应用到广泛的Linux环境。...监控工具kafka-manager 官网:https://github.com/yahoo/kafka-manager kafka-manager的数据主要来源两个方便:一是kafka的zookeeper.../local/jdk/bin/java kafka-manager" "/data/kafka/kafka-manager/bin/kafka-manager -Dconfig.file=/data/kafka...设置JMX_PORT是为方便kafka-manager管理kafka。
如果没装,出门右转,先把jdk搞完再回来接着看,linux安装jdk环境 ---- 搭建zookeeper集群 虽然kafka 0.5.x 以上版本已经集成了zk,但我们最好还是单独部署一套...1、进入/opt目录,创建kafka文件夹 mkdir /opt/kafka cd /opt/kafka 2、进去下载kafka安装包 wget https://archive.apache.org/...kafka 进入kafka的config目录 cd /opt/kafka/kafka_2.11-1.0.0/config/ 里面有个 server.properties 文件 把这个文件重命名并且复制两份...kafka服务 cd /opt/kafka/kafka_2.11-1.0.0 ...." 再次启动,如果还提示内存不足 清下机器缓存 sync echo 3 > /proc/sys/vm/drop_caches 如果不是以上原因,就只能根据启动日志来灵活解决了 其它kafka常用命令
: 添加用户 userdel: 删除用户 passwd: 修改用户密码 groupadd: 添加用户组 groupdel: 删除用户组 软件包管理: apt 或 yum: 包管理工具(取决于Linux
Linux常用命令 Shell是运维和系统管理员操作Linux系统的首选,简单的说,它是一个命令解释器。...如:ls text[1-3] 或 ls test[a-z] 示例: ls *1 ——>test1 ls test[123] --> test1 test2 test3 Linux 下环境下有几种不同...---- man **作用:**Linux为所有命令和系统调用编写了帮助手册。使用man命令可以方便地获取某个命令的帮助信息。 **用法:**man [手册编号] 命令名,手册编号可以省略。...---- vim vim是UNIX和Linux上标配的编辑器,功能十分强大。 vim xxx 插入模式 输入字符,并可以按光标键移动输入字符位置。
今天来安装kafka 安装kafka前台必须安装zookeeper 一、安装kafka 下载kafka两种方式 1、手动下载 下载地址:http://kafka.apache.org.../bin/bash #启动zookeeper /DATA/kafka/kafka_2.12-2.0.0/bin/zookeeper-server-start.sh /DATA/kafka/kafka_2.12.../bin/bash #关闭zookeeper /DATA/kafka/kafka_2.12-2.0.0/bin/zookeeper-server-stop.sh /DATA/kafka/kafka_2.12.../DATA/kafka/kafka_2.12-2.0.0/config/server.properties & 关闭命令: 关闭kafka: 在kafka目录下执行 ....终、、 ---- 以上就是linux安装kafka方法,有什么问题可以联系我哈。 ---- 感谢一路支持我的人。。。。。
外网无法连接Kafka集群(报错:NoBrokersAvailable) 本地Consumer和Producer无法使用远程Kafka服务器的解决方法: 分别修改各台服务器Kafka配置文件server.properties...文章 一、安装kafka 1、手动下载 下载地址:http://kafka.apache.org/downloads ?...: wget http://mirrors.hust.edu.cn/apache/kafka/2.0.0/kafka_2.12-2.0.0.tgz 二、解压kafka: ?...十、到此结束kafka单机版本就集成了 我们来停止kafka网上有很多脚本 你们可以参考一下 关闭脚本:进入kafka目录下 输入命令:vi kafkaStop.sh #!.../logs/zookeeper.log & 关闭kafka: 在kafka目录下执行.
linux目录结构: linux不像Windows 分了盘,它根目录下有如下常用文件夹: home ---------- 用户的家 root --...超级管理员root的家 etc ---------- 存放配置文件 usr ---------- 存放共享资源 常用命令...6、其他常用命令: ①、grep命令 grep category a.txt 表示在a.txt中查找category字符串所在的行,前提是打开了a.txt文件。...底行模式有如下常用命令: q 不保存退出 q! 不保存强制退出 wq 保存退出 8、管道: 管道:|,将一个命令的输出作为另一个命令的输入。
以下是kafka常用命令行总结: 1.查看topic的详细信息 ..../bin/kafka-topics.sh –zookeeper127.0.0.1:2181–alter –partitions20–topic testKJ1 5、kafka生产者客户端命令 ..../kafka-console-producer.sh --broker-list localhost:9092--topic testKJ1 6、kafka消费者客户端命令 ..../kafka-console-consumer.sh -zookeeper localhost:2181--from-beginning --topic testKJ1 7、kafka服务启动 ..../kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic testKJ1 --zookeeper127.0.0.1:2181
-c 创建一个新tar文件 -v 显示运行过程的信息 -f 指定文件名 -z 调用gzip命令进行压缩 -t 查看压缩文件的内容 -x 解开tar文...
这个目录存放着经常使用的命令 /sbin s就是Super User的意思,这里存放的是系统管理员使用的系统管理程序/home 存放着普通用户的主目录,在Linux.../usr 这是一个非常重要的目录,用户的很多应用程序和文件都放在这个目录下,类似于windows下面的program files目录/boot 这里存放的是启动Linux...这个目录是一个虚拟的目录,他是系统内存的映射,我们可以通过直接访问这个目录来获取系统信息/srv service缩写,该目录存放一些服务启动之后需要提取的数据 /sys 这是linux2.6...这个目录是用来存放一些临时文件的 /dev 类似于windows的设备管理器,把所有的硬件用文件的形式存储 /media linux...系统会自动识别一些设备,例如U盘,光驱等等,当时识别后,linux会把识别的设备挂载到这个目录下/mnt 系统提供该目录是为了让用户临时挂载别的文件系统,我们可以将外部的存储挂载在/mnt/
参考资料 https://www.bilibili.com/video/av15976434/#page=5 Linux工具快速教程 https://www.cnblogs.com/zengjs/p/3169473....html 文件压缩与解压 linux 查看目录下文件个数 基本指令 ls 统计某文件夹下文件的个数 ls -l |grep "^-"|wc -l 统计某文件夹下目录的个数 ls -l |grep...-name "*.DCM" | wc -l 统计当前目录以及子目录中包含.DCM字符的文件数目 //在Linux中,|表示将上一条输出作为下一条命令的输入,wc -l表示只显示列数 ls -l |grep...du -h //查看当前文件夹下所有文件夹及子文件夹大小 mv mv 源文件夹路径 目标文件夹路径移动(剪切)文件夹 zip http://www.codeceo.com/article/linux-zip-unzip-command.html...-u username杀死某个用户所有进程 watch watch -n 1 nvidia-smiwatch可以监视系统状态,该命令可以每秒刷新nvidia-smi的状态 通过SSH远程控制Linux
1.linux查找目录下的所有文件中是否含有某个字符串 grep -rn “查找名称” *; 2.查看当前目录内存使用情况 #du 文件名 -h #ll -h 3.
菜鸟教程快速查看:https://www.runoob.com/linux/linux-command-manual.html 快速导航:本网页直接拼接#命令名即可快速定位 ps lsof kill whoami
,kill进行杀掉 ps -A # 显示进程信息 ps -u root # 显示root进程用户信息 kill -9 port # 中断进程进行退出 kill port # 强制退出 运行级别 linux...init 0 立刻关机 2、poweroff 立刻关机 3、shutdown -h now 立刻关机(root用户使用) 4、shutdown -h 10 10分钟后自动关机 返回 需要注意的是linux...cd - # 返回上次的工作目录 cd ~ #进入当前用户 cd / #进入根目录 磁盘 查看系统的磁盘占用信息 df -kh #查看磁盘大小 free # 查看磁盘占用 目录 查看linux...目录树信息,其中tree需要单独安装 pwd #显示当前目录 dirs #显示当前目录 tree # 目录树 . ├── jjjj │ └── j.txt └── kkk 查看 linux...#停止/释放 swapon -a #再次开启 dos2unix 该命令做物联网开发的小伙伴可能会遇到 dos2unix windowsfile # Windows格式文本转换为Unix&Linux
传送门:CentOS 7 开启防火墙及开放指定端口 查看所有任务进程 ps -aux 查看某个进程是否在运行,java为例,可查看到PID ps -ef|gre...
head -1;ps -aux |grep -v "USER" | sort -nr -k 3 | headps -aux --sort=-pcpu|head -1011、查看系统内存free -h12、Linux
领取专属 10元无门槛券
手把手带您无忧上云