测试中间件 - Kafka Tool 快速入门(二)

本文涉及的产品
性能测试 PTS,5000VUM额度
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
注册配置 MSE Nacos/ZooKeeper,118元/月
简介: 测试中间件 - Kafka Tool 快速入门(二)

Topic

Topic 的概念可以简单理解成生产者到消费者之间进行数据传递时,当数据规模大到一定程度,每个消费者消费的业务数据都可能不一样,但是数据那么多又集中在管道里,消费者是怎么区分我应该消费哪条数据是我该消费的呢?


此时 Topic 来了,只要生产者发送该数据时,往指定的 topic 管道里发送,消费者也只监听该 topic 管道,说明我监听来的数据一定是我想要的,因为双方“暗号”对上啦~


image.png


分析消息体(重点)

通过以下箭头操作,就可以看到其中一个 Topic 的消息记录

Partition:与 Redis db 类似,也是 kafka 内部的小数据库分区

Message(重点):消息的详情内容

Timestamp:时间戳,生产者发送时间

image.png



我们选择第一条数据来作为示例,我们只需要关注【Message】【Headers】这两栏就够了

注意:他们都可以切换右上角的【View As】进行数据格式化查看

Message:类型 Http 里的 Body

Headers:类似 Http 里的 Header

image.pngimage.png

目录
打赏
0
8
11
26
37
分享
相关文章
【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka
【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka
3346 0
如何测试中间件优化后的 Pinia 状态管理?
如何测试中间件优化后的 Pinia 状态管理?
99 64
go高并发之路——消息中间件kafka
本文介绍了高并发业务中的流量高峰应对措施,重点讲解了Kafka消息中间件的使用,包括常用的Go语言库sarama及其版本问题,以及Kafka的版本选择建议。文中还详细解释了Kafka生产者的四种分区策略:轮询、随机、按Key和指定分区,并提供了相应的代码示例。
go高并发之路——消息中间件kafka
解锁Kafka等消息队列中间件的测试之道
在这个数字化时代,分布式系统和消息队列中间件(如Kafka、RabbitMQ)已成为日常工作的核心组件。本次公开课由前字节跳动资深专家KK老师主讲,深入解析消息队列的基本原理、架构及测试要点,涵盖功能、性能、可靠性、安全性和兼容性测试,并探讨其主要应用场景,如应用解耦、异步处理和限流削峰。课程最后设有互动答疑环节,助你全面掌握消息队列的测试方法。
【Azure 事件中心】使用Kafka的性能测试工具(kafka-producer-perf-test)测试生产者发送消息到Azure Event Hub的性能
【Azure 事件中心】使用Kafka的性能测试工具(kafka-producer-perf-test)测试生产者发送消息到Azure Event Hub的性能
【一键解锁!】Kafka Manager 部署与测试终极指南 —— 从菜鸟到高手的必经之路!
【8月更文挑战第9天】随着大数据技术的发展,Apache Kafka 成为核心组件,用于处理实时数据流。Kafka Manager 提供了简洁的 Web 界面来管理和监控 Kafka 集群。本文介绍部署步骤及示例代码,助您快速上手。首先确认已安装 Java 和 Kafka。
758 4
使用kafka自带脚本进行压力测试
使用kafka自带脚本进行压力测试
101 0
单元测试问题之编写单元测试时运行环境、数据库、中间件问题如何解决
单元测试问题之编写单元测试时运行环境、数据库、中间件问题如何解决
102 0
消息中间件(RocketMQ、RabbitMQ、ActiveMQ、Redis、kafka、ZeroMQ)以及之间的区别
消息中间件(RocketMQ、RabbitMQ、ActiveMQ、Redis、kafka、ZeroMQ)以及之间的区别
快速入门 Kafka 和 Java 搭配使用
快速入门 Kafka 和 Java 搭配使用
267 0

相关产品

  • 云消息队列 Kafka 版