当前位置: 首页 > news >正文

kafka运维常用命令

KAFKA常用命令

    • 一、KAFKA常用命令
      • 1.1kafka造数
      • 1.2kafla抓包
        • 1.2.1实时查看kafka数据
        • 1.2.2查看kafka历史数据
        • 1.2.3查看kafka中带有某个ip的历史数据
        • 1.2.4将kafka数据存入文件中

一、KAFKA常用命令

1.1kafka造数

示例:给topic为 ids-test 造数
./kafka-console-producer.sh --broker-list ip:9092 --topic ids-test

1.2kafla抓包

1.2.1实时查看kafka数据

./kafka-console-consumer.sh --bootstrap-server ip:9092 --topic topic的名字

1.2.2查看kafka历史数据

./kafka-console-consumer.sh --bootstrap-server ip:9092 --topic topic的名字 --from-beginning

1.2.3查看kafka中带有某个ip的历史数据

./kafka-console-consumer.sh --bootstrap-server ip:9092 --topic topic的名字 --from-beginning | grep IP地址

1.2.4将kafka数据存入文件中

./kafka-console-consumer.sh --bootstrap-server ip:9092 --topic topic名字 > /tmp/1.log

如果针对多次输入内容,希望添加到同一个文件内,需要将>修改为>>表示追加,但在不熟悉的时候不建议使用;

相关文章:

  • 北京网站建设多少钱?
  • 辽宁网页制作哪家好_网站建设
  • 高端品牌网站建设_汉中网站制作
  • 存储实验:华为异构存储在线接管与在线数据迁移(Smart Virtualization Smart Migration 特性)
  • C++ //练习 17.12 使用前一题中的数据结构,编写一个函数,它接受一个问题编号和一个表示真/假解答的值,函数根据这两个参数更新测验的解答。
  • 【轻松拿捏】什么是多态?如何在 Java 中实现多态?
  • 30. 串联所有单词的子串【 力扣(LeetCode) 】
  • 暑假算法刷题日记 Day 10
  • 记录jenkins的一个错误
  • 微信小程序request的请求格式是什么
  • 搭建内网开发环境(一)|基于docker快速部署开发环境
  • ES高级查询Query DSL查询详解、term术语级别查询、全文检索、highlight高亮
  • 学习日志8.14--ALC(Access Control List)访问控制列表
  • 一分钟学会Linux交换分区
  • 【Python深度学习】图像分割经典网络:U-Net
  • 官方招募 | 仓颉语言三方库社区建设全速启航,全球开发者、技术大神只等您!
  • 掌握CSS的时间之旅::past和:future伪类的探索与应用
  • AI工作流:低代码时代的革新者,重塑手机问答类应用生态
  • [rust! #004] [译] Rust 的内置 Traits, 使用场景, 方式, 和原因
  • conda常用的命令
  • IndexedDB
  • js 实现textarea输入字数提示
  • Odoo domain写法及运用
  • Redis中的lru算法实现
  • SegmentFault 技术周刊 Vol.27 - Git 学习宝典:程序员走江湖必备
  • Twitter赢在开放,三年创造奇迹
  • 创建一种深思熟虑的文化
  • 个人博客开发系列:评论功能之GitHub账号OAuth授权
  • 回流、重绘及其优化
  • 如何学习JavaEE,项目又该如何做?
  • 腾讯优测优分享 | Android碎片化问题小结——关于闪光灯的那些事儿
  • ​1:1公有云能力整体输出,腾讯云“七剑”下云端
  • ​DB-Engines 12月数据库排名: PostgreSQL有望获得「2020年度数据库」荣誉?
  • ​字​节​一​面​
  • (1)(1.9) MSP (version 4.2)
  • (2)(2.4) TerraRanger Tower/Tower EVO(360度)
  • (vue)el-cascader级联选择器按勾选的顺序传值,摆脱层级约束
  • (二)什么是Vite——Vite 和 Webpack 区别(冷启动)
  • (黑客游戏)HackTheGame1.21 过关攻略
  • (介绍与使用)物联网NodeMCUESP8266(ESP-12F)连接新版onenet mqtt协议实现上传数据(温湿度)和下发指令(控制LED灯)
  • (牛客腾讯思维编程题)编码编码分组打印下标(java 版本+ C版本)
  • (十六)串口UART
  • (数位dp) 算法竞赛入门到进阶 书本题集
  • (译)2019年前端性能优化清单 — 下篇
  • .htaccess配置常用技巧
  • .net core 6 集成 elasticsearch 并 使用分词器
  • .net core 连接数据库,通过数据库生成Modell
  • .Net Memory Profiler的使用举例
  • .net安装_还在用第三方安装.NET?Win10自带.NET3.5安装
  • .net程序集学习心得
  • .net连接oracle数据库
  • ?.的用法
  • [ vulhub漏洞复现篇 ] JBOSS AS 4.x以下反序列化远程代码执行漏洞CVE-2017-7504
  • []常用AT命令解释()
  • [20160807][系统设计的三次迭代]
  • [ABP实战开源项目]---ABP实时服务-通知系统.发布模式
  • [AIGC] SpringBoot的自动配置解析
  • [AMQP Connection 127.0.0.1:5672] An unexpected connection driver error occured