kafka命令
深入学习shell命令-grep
grep 命令格式 man grep 对 grep 命令的说明如下： grep - print lines matching a pattern grep [OPTIONS] PATTERN [FILE...] grep [OPTIONS] [-e PATTERN | -f FILE] [FILE. ......
常用DOS命令
Windows电脑上， 1、同时按 Win+r 按键 2、在弹出的命令提示符中 输入： cmd 然后回车 3、进入盘符，如进入D盘，输入命令： D： 然后回车 4、复制 命令到 cmd的运行窗口中用鼠标右键粘贴，不要用快捷键。 ......
STATA which命令功能
STATA which命令： which命令： which 命令名称 显示"命令名称"是内在的命令还是由某个ado文件 定义的命令 显示命令regress是由特定位置的regress.ado文件来完成，更新时间：2020 12 9 which regress // D:\Stata17\ado\ba ......
python 使用 kafka
python 使用 kafka 说明：关于 kafka 的启动与安装，命令行的使用，此处不做过多的解释，本篇文章主要描述 kafka 在 python 中的使用； 1. python 使用 kafka 生产者 **说明：**python 在操作 kafka 写入数据的时候，分为发送往已经存在的主题或 ......
巧用Grep 命令
导读 所有的类linux系统都会提供一个名为grep(global regular expression print，全局正则表达式输出)的搜索工具。grep命令在对一个或多个文件的内容进行基于模式的搜索的情况下是非常有用的。模式可以是单个字符、多个字符、单个单词、或者是一个句子。当命令匹配到执行命 ......
find命令
作用 find顾名思义就是查找文件，当然也可以查找目录 基本语法 find 路径 -命令参数 [输出形式] 路径就是从哪个地方开始搜索，不写默认为当前目录 输出形式有-print,-printf,-print0,-exec,-ok,-ls 输出形式 exec 命令名称 {} 对符合条件的文件执行所给 ......
java——spring boot集成kafka——单播与多播消息的实现
单播消息的实现： 单播消息：⼀个消费组⾥ 只会有⼀个消费者能消费到某⼀个topic中的消息。于是可以创建多个消费者，这些消费者在同⼀个消费组中。 创建一个消费者，此消费者属于消费组testGroup，获取borker为：10.31.167.10:9092中 主题为test的消息； ./kafka-c ......
wsl 中 docker-compose 搭建 kafka 集群出现的外部访问错误
在 wsl 中用 docker-compose 搭建了一台 zookeeper + 三台 broker 的 kafka 集群，使用的镜像是 bitnami/kafka，在按照镜像文档运行容器后，发现运行在宿主机里的客户端程序无法正确的推送/消费消息，研究后发现镜像文档只适用于客户端程序和 kafka ......
java——spring boot集成kafka——单节点示例
首先安装一个zk。然后再安装kafka： 执⾏以下命令创建名为“test”的topic，这个topic只有⼀个partition，并且备份因⼦也设置为1： 然后在kafka节点下，执行如下命令： ./kafka-topics.sh --create --zookeeper 172.16.253.35 ......
Kafka快速使用与详解
一、Kafka简介 1. 概念 Kafka是一个分布式的、基于发布/订阅的消息队列，最初由LinkedIn开发，并于2011年成为Apache项目的一部分。Kafka具有高吞吐量、可扩展性、持久性和容错性等特性，被广泛应用于大数据领域，如数据采集、数据传输、数据处理等场景。 Kafka主要由以下三个 ......
kratos中使用kafka不同group消费同一个topic的坑
参考项目地址 https://gitee.com/huoyingwhw/kratos_kafka.git 现象 像上图那样写的话，项目启动后，往topic中放入数据，只有article_group2会消费数据！ 原因 ～～～ ......
使用Node.js编写的命令行端口扫描器，功能完整，附带英文注解和使用说明
这是我花了一整天的时间写的node.js命令行扫描器，500多行代码，功能完整，附带英文注解和使用说明，可以拿来直接用。 const validOptions = [ { "name": "ports", "cmd": ["-p", "--ports"], "value": "21-23,25,80 ......
Windows下Nginx的启动、停止、重启等命令
假设安装在 C:\server\nginx-1.0.2目录： 1、启动： C:\server\nginx-1.0.2>start nginx 或者 C:\server\nginx-1.0.2>nginx.exe 注：建议使用第一种，第二种会使cmd窗口一直处于执行中，不能进行其他命令操作。 2、停止 ......
Kafka消费者
消费者读取消息。在其他基于发布与订阅的消息系统中，消费者可能被称为订阅者 或 读者。
消费者订阅一个或多个主题，并按照消息生成的顺序读取它们。消费者通过检查消息的偏移量来区分已经读取过的消息。 ......
Ubuntu常用命令
软件安装&卸载 sudo apt install <软件名> // 安装软件最简单的方式 sudo apt list // 查看所有已安装的软件列表 sudo apt search <软件名> // 搜索某个软件 sudo apt remove <软件名> // 删除某个软件包 sudo apt p ......
Linux目录结构和命令提示符
一、Linux目录结构 一、Linux目录结构 一切皆文件！！！！！ / 根目录 /root root用户的家目录/宿主目录 /home 普通用户的家目录/宿主目录 userA /home/userA userB /home/userB /etc 应用程序的配 ......
Linux——命令（一）
在虚拟机中，打开Linux系统，登录root用户，便可看到一串字符串 [root@localhost ~]# [当前用户名@简写主机名 ~] # root：显示的是当前的登录用户 @：分隔符号，没有特殊含义。 localhost：当前系统的简写主机名（完整主机名是 localhost.localdo ......
P1 命令行连接到MySql
使用命令行窗口连接MySQL数据库 mysql -h 主机名 -P 端口 -u 用户名 -p密码 注意： (1) “-p密码”之间不要有空格 (2) -p后面如果没有写密码，回车会要求输入密码 (3) 如果没有写 -h 主机，默认就是本机 (4) 如果没有写 -P 端口，默认就是3306 (5) 在 ......
linux命令小计
当添加github 的ssh key的时候报key alread in use， 但是有不确认在那个项目设置的。 可以使用如下命令确认 ssh -T -ai ~/.ssh/id_rsa git@github.com ......
linux抓包命令收集
抓包 tcpdump tcpdump - dump traffic on a network tcpdump是一个用于截取网络分组，并输出分组内容的工具。凭借强大的功能和灵活的截取策略，使其成为类UNIX系统下用于网络分析和问题排查的首选工具 tcpdump 支持针对网络层、协议、主机、网络或端口的 ......
ulimit文件限制命令
当进程打开现有文件或创建新文件时，会受到文件描述符的限制。 Linux系统中经常出现错误too many open files ，说明你打开的文件数量超过文件描述符的限制。 查看文件描述符大小： [root@centos7-190:mysql]$ ulimit -n102412修改文件描述符大小： ......
Linux终端命令相关
匹配F:\ 不要用双引号 grep -nr 'F:\\' xargs xargs可以把前面的结果传递到后面，就不用``，更好用 find -name 'file' | xargs grep -rl 'keyword' | xargs sed -i 's/keyword/replaceword/g' ......
C/CPP在命令行中生成DLL文件
简单的写一个C调用DLL（动态链接库）的例子。 创建3个.c文件备用 test.c 1 #include <stdio.h> 2 3 //这里声明，表示来自dll文件。 4 extern int Add(int,int); 5 extern int Square(int); 6 extern int ......
linux命令
文件管理 目录操作 切换目录 cd 查看目录 ls -l 列出文件详细信息 或者直接ll -a 列出当前目录下所有文件及目录，包括隐藏的a(all) 创建目录 mkdir -p 创建目录，若无父目录，则创建p(parent) 输出信息 echo 打印文件到命令行(查看文件) cat 改变文件所属用户 ......
构建一个flink程序,从kafka读取然后写入MYSQL
最近flink已经变得比较流行了，所以大家要了解flink并且使用flink。现在最流行的实时计算应该就是flink了，它具有了流计算和批处理功能。它可以处理有界数据和无界数据，也就是可以处理永远生产的数据。具体的细节我们不讨论，我们直接搭建一个flink功能。总体的思路是source -> tra ......
kafka学习
https://github.com/Snailclimb/springboot-kafka/blob/master/docs/3-10%E5%88%86%E9%92%9F%E5%AD%A6%E4%BC%9A%E5%A6%82%E4%BD%95%E5%9C%A8SpringBoot%E7%A8%8B ......
Linux操作命令（N）
1、输出图形文字 banner 可以先使用如下命令安装： sudo apt-get update sudo apt-get install sysvbanner 例1：banner shiyanlo 例2：printerbanner -w 50 B 2、查看文件权限 2.1修改文件权限 3、看当前登 ......