kafka查看消息两种方式（命令行和软件）

9月前作者：goxingman 分类：Toy博客阅读(43) 违法举报

这篇具有很好参考价值的文章主要介绍了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

kafka查看消息两种方式（命令行和软件）,kafka,分布式

kafka查看消息两种方式（命令行和软件）,kafka,分布式

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

③设置 Kafka 数据展示格式

kafka查看消息两种方式（命令行和软件）,kafka,分布式

④查看数据

kafka查看消息两种方式（命令行和软件）,kafka,分布式

⑤发送消息

kafka查看消息两种方式（命令行和软件）,kafka,分布式

kafka查看消息两种方式（命令行和软件）,kafka,分布式文章来源地址https://www.toymoban.com/news/detail-601622.html

到了这里，关于kafka查看消息两种方式（命令行和软件）的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：

领支付宝红包赞助服务器费用

分布式 - 消息队列Kafka：Kafka 消费者消费位移的提交方式

最简单的提交方式是让消费者自动提交偏移量，自动提交 offset 的相关参数： enable.auto.commit：是否开启自动提交 offset 功能，默认为 true; auto.commit.interval.ms：自动提交 offset 的时间间隔，默认为5秒；如果 enable.auto.commit 被设置为true，那么每过5秒，消费者就会自动提交 poll() 返

2024年02月12日
浏览(48)
kafka查看topic和消息内容命令

①创建一个测试用的topic ② 用Kafka的console-producer在topic test 生产消息 ③ 用Kafka的console-consumer 消费topic test的消息 ④查询topic，进入kafka目录： ⑤查询topic内容： ⑥查看topic 为 test的详细信息 ⑦往topic 为 test的内部生产消息 ⑧从topic 为test的内部消费消息 ⑨删除kafka的测试top

2024年02月11日
浏览(56)
kafka 基础概念、命令行操作（查看所有topic、创建topic、删除topic、查看某个Topic的详情、修改分区数、发送消息、消费消息、查看消费者组、更新消费者的偏移位置）

kafka官网 Broker 一台kafka服务器就是一个broker，可容纳多个topic。一个集群由多个broker组成； Producer 生产者，即向kafka的broker-list发送消息的客户端； Consumer 消费者，即向kafka的broker-list订阅消息的客户端； Consumer Group 消费者组是逻辑上的一个订阅者，由多个

2024年02月01日
浏览(61)
Kafka - 消息队列的两种模式

消息队列确实可以根据消息传递的模式分为点对点模式发布/订阅模式这两种模式有不同的特点和应用场景：点对点模式（Point-to-Point，P2P）：在点对点模式中，有一个生产者（Producer）将消息发送到一个特定的队列（Queue）。只有一个消费者（Consumer）可以接收和处理队列

2024年02月08日
浏览(38)
分布式 - 消息队列Kafka：Kafka 消费者消息消费与参数配置

01. 创建消费者在读取消息之前，需要先创建一个KafkaConsumer对象。创建KafkaConsumer对象与创建KafkaProducer对象非常相似——把想要传给消费者的属性放在Properties对象里。为简单起见，这里只提供4个必要的属性：bootstrap.servers、key.deserializer 和 value.deserializer。 ① bootstrap.servers 指

2024年02月12日
浏览(45)
分布式 - 消息队列Kafka：Kafka生产者发送消息的分区策略

01. Kafka 分区的作用分区的作用就是提供负载均衡的能力，或者说对数据进行分区的主要原因，就是为了实现系统的高伸缩性。不同的分区能够被放置到不同节点的机器上，而数据的读写操作也都是针对分区这个粒度而进行的，这样每个节点的机器都能独立地执行各自分区的

2024年02月13日
浏览(54)
分布式消息服务kafka

什么是消息中间件？消息中间件是分布式系统中重要的组件，本质就是一个具有接收消息、存储消息、分发消息的队列，应用程序通过读写队列消息来通信。例如：在淘宝购物时，订单系统处理完订单后，把订单消息发送到消息中间件中，由消息中间件将订单消息分发到下

2024年02月01日
浏览(48)
【分布式技术】消息队列Kafka

目录一、Kafka概述二、消息队列Kafka的好处三、消息队列Kafka的两种模式四、Kafka 1、Kafka 定义 2、Kafka 简介 3、Kafka 的特性五、Kafka的系统架构六、实操部署Kafka集群步骤一：在每一个zookeeper节点上完成kafka部署编辑步骤二：传给其他节点步骤三：启动3个节点 kafka管理

2024年01月23日
浏览(55)
Spring-Kafka 发送消息的两种写法

本文主要是使用 Java 语言中 spring-kafka 依赖对 Kafka 进行使用。使用以下依赖对 Kafka 进行操作：需要更改版本的话，可以前往：Maven 仓库创建项目，先创建一个简单的 Maven 项目，删除无用的包、类之后，使用其作为一个父级项目。以下内容如果在项目启动时报这个错：把

2024年01月20日
浏览(47)
分布式 - 消息队列Kafka：Kafka 消费者的消费位移

01. Kafka 分区位移对于Kafka中的分区而言，它的每条消息都有唯一的offset，用来表示消息在分区中对应的位置。偏移量从0开始，每个新消息的偏移量比前一个消息的偏移量大1。每条消息在分区中的位置信息由一个叫位移（Offset）的数据来表征。分区位移总是从 0 开始，假设一

2024年02月12日
浏览(50)