启动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
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
/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文件。
--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
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目录下执行.
以下是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
linux目录结构: linux不像Windows 分了盘,它根目录下有如下常用文件夹: home ---------- 用户的家 root --...超级管理员root的家 etc ---------- 存放配置文件 usr ---------- 存放共享资源 常用命令...6、其他常用命令: ①、grep命令 grep category a.txt 表示在a.txt中查找category字符串所在的行,前提是打开了a.txt文件。...底行模式有如下常用命令: q 不保存退出 q! 不保存强制退出 wq 保存退出 8、管道: 管道:|,将一个命令的输出作为另一个命令的输入。
-c 创建一个新tar文件 -v 显示运行过程的信息 -f 指定文件名 -z 调用gzip命令进行压缩 -t 查看压缩文件的内容 -x 解开tar文...
传送门:CentOS 7 开启防火墙及开放指定端口 查看所有任务进程 ps -aux 查看某个进程是否在运行,java为例,可查看到PID ps -ef|gre...
这个目录存放着经常使用的命令 /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/
1.Linux文件夹的目录结构 / 根目录【linux下只有一个根路径】 /bin 存放可执行的二进制文件 如常用命令:ls,tar等 /sbin 系统二进制执行文件目录...sbin 超级用户的一些管理程序 /etc 系统配置文件存放的目录【不建议在该目录存放可执行文件】 /home 默认的用户目录 /lib 系统使用的函数库目录 /dev 存放linux...系统下的设置文件 /usr 用于存放系统的应用程序 2.Linux命令格式 command [-options] [parameter] command:命令名称 [-options]:选项... > 1,txt 将linux字符串写入文件 ls -hl > 1.txt 将列表写入文件 >> 文件名 重定向, 将输出内容追加到指定文件中【不覆盖】 例: echo... linux >> 1.txt ls -hl >> 1.txt 管道 | 将第一个命令的输出结果做完第二个命令的参数 例: ls -lh | more 分页查询列表
Linux软件包管理 dpkg (Debian Package)管理工具,软件包名以.deb后缀。这种方法适合系统不能联网的情况下。...比如安装tree命令的安装包,先将tree.deb传到Linux系统中。再使用如下命令安装。...1.5.3-1_i386.deb 安装软件 sudo dpkg -r tree 卸载软件 注:将tree.deb传到Linux...sudo chown root:root jdk-7u21-linux-i586.tar.gz 文件权限管理 三种基本权限 R 读 数值表示为4 W ...如图所示,jdk-7u21-linux-i586.tar.gz文件的权限为-rw-rw-r-- -rw-rw-r--一共十个字符,分成四段。
参考资料 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
一般情况下进入tomcat/bin路径下shutdown.sh关闭,再放入项目文件启动即可
Linux中许多常用命令是必须掌握的,这里将我学linux入门时学的一些常用的基本命令分享给大家一下,希望可以帮助你们。 date #显示或设定系统的日期与时间。...find #用于在文件树中查找文件,并作出相应的处理 -name 按照文件名查找文件 chmod #改变linux系统文件或目录的访问权限 chown #将指定文件的拥有者改为指定的用户或组...合用,表示在进程ID,PID死掉之后结束 -q, --quiet, --silent 从不输出给出文件名的首部 -s, --sleep-interval=S 与-f合用,表示在每次反复的间隔休眠S秒 Linux...--permanent --remove-port=8080/tcp #重启防火墙(修改配置后要重启防火墙) firewall-cmd --reload # 参数解释 1、firwall-cmd:是Linux
领取专属 10元无门槛券
手把手带您无忧上云