kafka查看消息两种方式(命令行和软件)+另附发送消息方式

1、命令行方式

①找到kafka安装文件夹

②执行命令

#指定offset为指定时间作为消息起始位置
kafka-consumer-groups.sh \
--bootstrap-server 20.2.246.116:9092 \
--group group_1 \
--topic lanxin_qiao \
--reset-offsets \
--to-datetime 2023-07-19T01:00:00.000 \
-execute#打印输出消息到msg.txt
kafka-console-consumer.sh \
-topic lanxin_qiao \
--bootstrap-server 20.2.246.116:9092 \
--group group_1 >msg.txt 2>&1

2、软件方式

①软件下载地址:https://www.kafkatool.com/download2/offsetexplorer_64bit.exe

 

 

②然后点击test试一下能不能连上

③设置 Kafka 数据展示格式

④查看数据

⑤发送消息

 

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

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

相关文章

MySQL-Linux安装

JDK安装(linux版) CentOS7环境: jdk下载地址huaweicloud.com 创建目录: mkdir /opt/jdk通过 ftp 客户端 上传 jdk压缩包(linux版本)到 1中目录进入目录:cd /opt/jdk解压:tar -zxv…

QWebEngineView添加chrome参数的方法

开启Chrome DevTools开发者工具 在chrome浏览器调试前端页面,请使用以下方法之一: 方法一:设置环境变量:QTWEBENGINE_REMOTE_DEBUGGING1112 方法二:添加启动参数:--remote-debugging-port1112 方法三&a…

查看自己的ip地址的网站

有时候需要知道自己的ip地址,可以上这个网站查看: What Is My IP? Best Way To Check Your Public IP Address 网站的域名是https://www.whatismyip.com/ 还是挺好记的。

【Redis笔记】基于Redis的Stream结构作为消息队列,实现异步任务

使用redis命令创建消息队列 在redis-cli中执行如下指令 XGROUP CREATE key groupName ID [MKSTREAM]key:队列名称 groupName:消费者组名称 ID:起始ID标示,$代表队列中最后一个消息,0代表队列中第一个消息 MKSTREAM:队列不存在时…

一篇了解电感的使用

一、电感理论基础 1.电感的定义 当电流通过线圈后,会产生磁场,磁感线穿过线圈,产生的磁通量与电流 i有如下关系: 将漆包线、纱包线或塑皮线等在绝缘骨架或磁心、铁心上绕制而成的器件,当线圈通过电流后,在…

linux应用程序需要编写的脚本

每一个程序都按照下面的要求进行脚本编写 多个应用之间联合安装采用编写外围脚本,依次调用多个应用的脚本的方式实现

负载均衡 dubbo

1 自定义负载均衡 dubbo 在 Dubbo 中,用户可以自定义负载均衡策略以满足特定场景的需求。Dubbo 提供了扩展接口 com.alibaba.dubbo.rpc.cluster.LoadBalance 来支持自定义负载均衡算法。 要实现自定义的负载均衡策略,需要完成以下步骤: 创建…

MyBatis Oracle 批量插入数据

MyBatis Oracle 批量插入数据 1.需求描述2.实现方案2.1 循环 insert 插入2.2 insert all 插入2.3 insert union all 插入 3.分析总结 系统:Win10 JDK:1.8.0_351 IDEA:2022.3.3 1.需求描述 在一次项目中实施过程中,后台需要将地区…

给一篇word注音可不可以只要拼音不要汉字 word中如何只保留拼音不要汉字

word中如何只保留拼音不要汉字,如果你想要只保留拼音而去除汉字,可以通过一系列步骤来实现。以下是一个详细的教程,帮助你完成这个任务。 首先,确保你的电脑已经安装了“汇帮注音大师”软件。如果没有,你需要安装一下…

云计算 3月8号 (wordpress的搭建)

项目wordpress 实验目的: 熟悉yum和编译安装操作 锻炼关联性思维,便于以后做项目 nginx 编译安装 1、安装源码包 [rootlinux-server ~]# yum -y install gcc make zlib-devel pcre pcre-devel openssl-devel [rootlinux-server ~]# wget http://nginx.…

安卓7原生相机切到视频崩溃

目录 1、查看日志 2、分析日志、提取重点 3、寻找解决方法 author daisy.skye的博客_CSDN博客-嵌入式,Qt,Linux领域博主 daisy.skye_嵌入式,Linux,Qt-CSDN博客daisy.skye擅长嵌入式,Linux,Qt,等方面的知识https://blog.csdn.net/qq_40715266?typeblog 1、查看日志 由于安…

Java实战:利用Redis实现每周热评

本文将详细介绍如何利用Redis实现每周热评的功能。我们将深入探讨Redis的相关概念,如键值对、数据结构、过期时间等,以及如何使用Java语言结合Jedis库进行Redis操作。 1. 引言 在现代的互联网应用中,实时统计和展示热门内容是一种常见的需求…

C语言知识点总结-10.共用体、结构体、宏定义、位运算等

第十章、共用体、结构体、宏定义、位运算 10.1 共用体 在进行某些算法的C语言编程的时候,需要使几种不同类型的变量存放到同一段内存单元中。也就是使用覆盖技术,几个变量互相覆盖。这种几个不同的变量共同占用一段内存的结构,在C语言中,被称作“共用体”

vscode setting.json 全局设置 工作区设置 位置 优先级

vscode中setting.json有两种配置权限 一、全局配置:setting.json文件位于C:\Users\Administrator\AppData\Roaming\Code\User\settings.json 二、工作区配置:setting.json文件位于工作区的.vscode\settings.json 当两种配置同时存在时,工作区…

深入理解nginx一致性哈希负载均衡模块[下]

上接 深入理解nginx一致性哈希负载均衡模块[上] 3. 源码分析 nginx的一致性哈希功能是通过ngx_http_upstream_hash_module来提供的,下面来整体通过ngx_http_upstream_hash_module来学习一下一致性哈希算法的实现原理。 3.1 配置指令分析 要启用Nginx的一致性哈希负载均衡算法…

生成对抗网络 (GAN)

生成对抗网络(Generative Adversarial Networks,GAN)是由Ian Goodfellow等人在2014年提出的一种深度学习模型。GAN由两部分组成:一个生成器(Generator)和一个判别器(Discriminator)&…

一文学会搭建 cli 脚手架工具

文章目录 设置工具命令package.json bin 字段注释:#!/usr/bin/env node设置环境变量 接收命令选项参数process 实现commander 命令行交互:inquirer下载项目模板:download-git-repo执行额外命令:自动安装依赖child_processexeca 体…

取证工作:如何提取和破解网络浏览器用户密码

ElcomSoft 系列软件专注于破解及恢复广泛的应用环境(Office、数据库、归档文件、iOS等)、系统 (EFS加密等)、磁盘(BitLocker、FileVault 2、PGP Disk、TrueCrypt 和 VeraCrypt 加密)及网络浏览器的加密保护,是数据恢复…

基于卷积神经网络的野外可食用植物分类系统

温馨提示:文末有 CSDN 平台官方提供的学长 QQ 名片 :) 1. 项目简介 本文详细探讨了一基于深度学习的可食用植物图像识别系统。采用TensorFlow和Keras框架,利用卷积神经网络(CNN)进行模型训练和预测,并引入迁移学习模型…

Mac测试环境搭建

1 下载pycharm 下载地址:PyCharm:JetBrains 出品的用于数据科学和 Web 开发的 Python IDE 2 安装python3.6.8 下载地址:Index of /ftp/python/3.6.8/ 安装后提示错误 换一种方式:用conda 下载地址:Free Download | …