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

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

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

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

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

相关文章

  • Kafka - 消息队列的两种模式

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

    2024年02月08日
    浏览(30)
  • Spring-Kafka 发送消息的两种写法

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

    2024年01月20日
    浏览(31)
  • 查看kafka消息消费堆积情况

    查看主题命令 展示topic列表 描述topic 查看topic某分区偏移量最大(小)值 增加topic分区数 删除topic:慎用,只会删除zookeeper中的元数据,消息文件须手动删除 方法一: 方法二: 待验证 查看topic消费进度,必须参数为–group, 不指定–topic,默认为所有topic, 列出所有主题中的

    2024年03月13日
    浏览(67)
  • Springboot使用kafka的两种方式

    在Spring Boot中使用Apache Kafka主要有两种方式:使用Spring Kafka项目和使用Spring Boot的spring-boot-starter-kafka。以下是这两种方式的简要概述: 使用Spring Kafka项目 Spring Kafka是Spring官方提供的一个用于Apache Kafka的集成库。虽然它不是一个Spring Boot专用的库,但它可以与Spring Boot很好地集

    2024年02月20日
    浏览(42)
  • Kafka查看消息是否堆积(服务器)

    查询消费组 先进入kafka中的bin目录 ./kafka-consumer-groups.sh --bootstrap-server ip:9092 --list  查询消费组的消费情况 ./kafka-consumer-groups.sh --bootstrap-server ip1:9092 --describe --group 组名称   解析 TOPIC :topic消息队列id CURRENT-OFFSET :当前消费的偏移量 LAG:消息堆积数量 查看分区中消息偏移量

    2024年02月06日
    浏览(34)
  • Spring RabbitMQ那些事(2-两种方式实现延时消息订阅)

    业务开发中有很多延时操作的场景,比如最常见的 超时订单自动关闭 、 延时异步处理 ,我们常用的实现方式有: 定时任务轮询 (有延时)。 借助Redission的延时队列 。 Redis的key过期事件通知机制 (需开启key过期事件通知,对Redis有性能损耗)。 RocketMQ中定时消息推送 (支

    2024年02月04日
    浏览(29)
  • 【SpringBoot系列】Springboot使用kafka的两种方式

    🤵‍♂️ 个人主页:@香菜的个人主页,加 ischongxin ,备注csdn ✍🏻作者简介:csdn 认证博客专家,游戏开发领域优质创作者,华为云享专家,2021年度华为云年度十佳博主 🐋 希望大家多多支持,我们一起进步!😄 如果文章对你有帮助的话, 欢迎评论 💬点赞👍🏻 收藏 📂

    2024年02月05日
    浏览(41)
  • Kafka使用MirrorMaker同步数据的两种方式

    MirrorMaker 是 Kafka官方提供的跨数据中心的 流数据同步方案 。原理是通过从 原始kafka集群 消费消息,然后把消息发送到 目标kafka集群 。操作简单,只要通过简单的 consumer配置和 producer配置,然后启动 Mirror,就可以实现准实时的数据同步。 这里需要确保 目标Kafka集群(接收数

    2023年04月14日
    浏览(32)
  • 分布式 - 消息队列Kafka:Kafka生产者发送消息的方式

    不管是把Kafka作为消息队列、消息总线还是数据存储平台,总是需要一个可以往Kafka写入数据的生产者、一个可以从Kafka读取数据的消费者,或者一个兼具两种角色的应用程序。 Kafka 生产者是指使用 Apache Kafka 消息系统的应用程序,它们负责将消息发送到 Kafka 集群中的一个或多

    2024年02月13日
    浏览(32)
  • 分布式 - 消息队列Kafka:Kafka生产者发送消息的3种方式

    不管是把Kafka作为消息队列、消息总线还是数据存储平台,总是需要一个可以往Kafka写入数据的生产者、一个可以从Kafka读取数据的消费者,或者一个兼具两种角色的应用程序。 Kafka 生产者是指使用 Apache Kafka 消息系统的应用程序,它们负责将消息发送到 Kafka 集群中的一个或多

    2024年02月13日
    浏览(36)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包