首页 > 其他分享 >腾讯Ckafka队列使用测评

腾讯Ckafka队列使用测评

时间:2023-10-27 17:32:38浏览次数:35  
标签:CKafka 发送 测评 队列 topic Ckafka 消息 监控 offset

产品购买活动链接

https://cloud.tencent.com/act/pro/618season?developercode=NEcnmZ18&from=20877 或者 https://cloud.tencent.com/act/pro/developer_business-scenario?developercode=NEcnmZ18&from=18122&from=20878

前言

本文主要是测试Ckafka的性能如何,作为一款商用的消息中间件,从消息的接收和处理,以及监控维度查看消息中间件的使用方便程度,比起自己搭建一个kafka的框架来说有什么省心的地方和优点缺点。

开始步骤

开通服务

选择合适的配置,这里是使用的活动试用版本。

腾讯Ckafka队列使用测评_kafka

查看实例

腾讯Ckafka队列使用测评_kafka_02

发送消息

从消息发送和处理的角度来看,支持高并发消息生产和消费,处理消息的速度非常快,响应时间很短,能够满足各种场景的需求。同时提供了多种消息确认机制,如同步和异步确认,可靠性非常高,能够保证消息的不丢失和不重复消费。此外,还支持消息的批量发送和批量消费,大大提高了处理消息的效率。

弹性topic

创建一个topic发送接收消息

腾讯Ckafka队列使用测评_发送消息_03

添加外网路由

会有默认的3M宽带支持

腾讯Ckafka队列使用测评_kafka_04

数据上报

也就是发送消息

腾讯Ckafka队列使用测评_kafka_05

配置ACL策略

发送消息需要给主题配置权限,绑定到某个具体的用户上。

腾讯Ckafka队列使用测评_外网_06

腾讯Ckafka队列使用测评_kafka_07

本地消息成功发送日志

Produce ok:my-topic-0@591
Produce ok:my-topic-0@592
Produce ok:my-topic-0@593
Produce ok:my-topic-0@594

Consume partition:0 offset:591
Consume partition:0 offset:592 
Consume partition:0 offset:593 
Consume partition:0 offset:594

消息监控

腾讯CKafka监控提供了丰富的指标,可以轻松监控集群的健康状况、生产者和消费者的情况,并及时发现和解决潜在的问题。此外,监控还支持自定义告警规则,并能够及时发送告警信息,可以让用户能够第一时间收到异常信息并做出相应的处理。

发送记录

腾讯Ckafka队列使用测评_kafka_08

实例监控

腾讯Ckafka队列使用测评_发送消息_09

主题监控

腾讯Ckafka队列使用测评_kafka_10

topic监控

腾讯Ckafka队列使用测评_kafka_11

总结

从体验感上面来说,本地去请求到Ckafka是延时很小的,网络这块还是处理的很小的,如果搭建一个集群,那就相当于内网建造一个集群,效果会更好,我这里是使用了外网进行发送消息,外网发送需要配置ip和帐户密码,提供了接口文档也很轻松。

最让我惊喜的是这个监控页面,估计kafka官方的都没这么好,非常的详细,什么时候发了什么消息消息内容是什么,一清二楚,另外就是看了下这里配置的是一个集群,免去了配置的成本,基本页面就可以操作一切,所以如果自己的项目手动搭建一套集群还是不建议,毕竟维护成本在那里,还不如花点钱买一个服务,实时的监控报警,非常清楚也很详细。

腾讯CKafka作为一个高性能、高可靠性的消息队列服务,非常适合企业级应用和高并发场景的使用。使用CKafka需要注意其规范和限制,并进行相应的配置和初始化,保证CKafka的稳定性和可靠性。可以根据业务需求选择适合的CKafka版本,如私有化部署版、云版等。在使用CKafka前,需要进行相关的配置和初始化。

在消息生产方面,可以使用API进行生产消息,同时也可以根据需要设置消息的发送模式、确认机制等。在消息消费方面,用户可以使用API进行消费消息,也可以根据需要设置消费者组、消息过滤等。

引用

CKafka服务


开通外网ip


添加路由

数据上报


订阅消费

标签:CKafka,发送,测评,队列,topic,Ckafka,消息,监控,offset
From: https://blog.51cto.com/stevenchendy/8061950

相关文章

  • 秒杀优化(阻塞队列实现)
    库存使用Redis的string类型进行存储下单人使用Redis的set类型进行存储,set类型中数据不可重复1.将优惠券数据存放到Redis中,通过Lua脚本实现对库存是否充足,用户是否下单,以及扣减库存的操作,Lua脚本时原子性的,要么成功,要么失败。2.开启异步线程,将数据存入数据库中,并发性能提高,秒杀耗时......
  • 堆栈模拟队列
    堆栈模拟队列题目大意PTA上的一道题,详题见文末。设已知有两个堆栈S1和S2,请用这两个堆栈模拟出一个队列Q。输入:32A1A2A3A4A5DA6DA7DA8DDDDT输出:ERROR:Full1ERROR:Full23478ERROR:Empty思路最开始设想的是将长度小的栈作为存储栈,长度大......
  • 灵活、可用、高扩展,EasyMR 带来全新 Yarn 的队列管理功能及可视化配置
    YARN(YetAnotherResourceNegotiator)是Hadoop生态系统中的资源调度器,主要用于资源管理和作业调度。YARN自身具备队列管理功能,通过对YARN资源队列进行配置和管理,实现集群资源的分配,以满足不同应用和用户的需求。YARN的引入为集群在利用率、资源统一管理和数据共享等方面带来......
  • 软件兼容性测试对软件产品起到什么作用?CMA、CNAS软件测评中心分享
    软件兼容性测试是指检查软件之间能否正确地进行交互和共享信息。随着用户对来自各种类型软件之间共享数据能力和充分利用空间同时执行多个程序能力的要求,测试软件之间能否协作变得越来越重要。软件兼容性测试工作的目标是保证软件按照用户期望的方式进行交互。1、提高软件......
  • 软件系统测试和验收测试有什么联系和区别?湖南软件测评公司推荐
    卓码软件测评作为一家专业的软件测试服务提供商,我们深知软件系统测试和验收测试在软件开发过程中的重要性。本文将从多个角度出发,详细描述这两个测试的含义、联系和区别。一、什么是软件系统测试?软件系统测试是指对整个软件系统进行全面、全局的功能和性能验证的过程......
  • Java双端队列Deque简述
    概述​ Deque是一个双端队列接口,继承自Queue接口,Deque的实现类是LinkedList、ArrayDeque、LinkedBlockingDeque,其中LinkedList是最常用的。​ Deque是一个线性collection,支持在两端插入和移除元素。名称deque是“doubleendedqueue(双端队列)”的缩写,通常读为“deck”。大多数......
  • Java队列Queue简述
    概述​ Queue是java中实现队列的接口,它总共只有6个方法,我们一般只用其中3个就可以了。Queue的实现类有LinkedList和PriorityQueue。最常用的实现类是LinkedList。Queue的6个方法分类抛出异常返回特殊值插入add(e)offer(e)删除remove()poll()检查element(......
  • 小白学算法-数据结构和算法教程: 队列的应用
    检查给定图是否是二分图二分图是一种图,其顶点可以分为两个独立的集合U和V,使得每条边(u,v)要么连接从U到V的顶点,要么连接从V到U的顶点。换句话说,对于每个边(u,v),要么u属于U,v属于V,要么u属于V,v属于U。我们也可以说,不存在连接同一集合的顶点的边。如果图着色......
  • RabbitMq---延时队列
    应对场景订单创建后--->开始锁库存而如果之后的服务出现异常,在订单创建的簇点会自动设置逻辑来处理但是之后解锁库存则需要延时队列来解决采用定时任务检查的话有以下问题:时效性(存在较大的时间误差):即使订单支付倒计时30min但是可能你正好在定时任务检查之后的1min时创......
  • 3.2 队列
    3.2.1队列的基本概念 注:数据结构三要素――逻辑结构、数据的运算、存储结构(物理结构> 栈(Stack)是只允许在一端进行插入或删除操作的线性表队列(Queue)是只允许在一端进行插入,在另一端删除的线性表重要术语:队头、队尾、空队列 队列的特点:先进先出FirstlnFirsto......