搜索结果
查询Tags标签： topic，共有 206条记录-
RabbitMQ 入门系列：5、基础编码：交换机的进阶介绍及编码方式。
系列目录RabbitMQ 入门系列：1、MQ的应用场景的选择与RabbitMQ安装。 RabbitMQ 入门系列：2、基础含义：链接、通道、队列、交换机。 RabbitMQ 入门系列：3、基础含义：持久化、排它性、自动删除、强制性、路由键。 RabbitMQ 入门系列：4、基础编码：官方SDK使用：链接创建…
2022/8/26 6:55:55 人评论 次浏览 -
kafka
另外找一个zk，有客户端命令的.\zkCli.cmd -server 127.0.0.1:2181ls /brokers 查看注册信息1，kafka不支持分布式事务消息 不支持消费失败重试 2，kafka的单机TPS能跑到每秒上百万，是因为Producer端将多个小消息合并，批量发向broker 3，RocketMQ写入性能上不如kafka, 主…
2022/8/16 23:23:40 人评论 次浏览 -
Windows下搭建kafka并通过命令消费
一、依赖环境准备1、检查JDK是否存在且和JVM版本一致，我这里系统是64位，JVM也是64位2、如果出现以下报错则是JVM不一致 二、安装kafka1、下载最新版本kafkakafka官方下载路径： https://kafka.apache.org/downloads.html我们下载官方推荐的最新版本kafka 3.2.1, Scala 2…
2022/8/15 5:24:32 人评论 次浏览 -
RocketMQ 延时消息
一、什么是延时消息 当消息写入到Broker后，不能立刻被消费者消费，需要等待指定的时长后才可被消费处理的消息，称为延时消息。 二、延时消息等级 RocketMQ延时消息的延迟时长不支持随意时长的延迟，是通过特定的延迟等级来指定的。默认支持18个等级的延迟消息，延时等级…
2022/8/11 6:23:21 人评论 次浏览 -
Kafka学习(十五) Python Kafka Client 性能测试
一、前言由于工作原因使用到了 Kafka，而现有的代码并不能满足性能需求，所以需要开发高效读写 Kafka 的工具，本文是一个 Python Kafka Client 的性能测试记录，通过本次测试，可以知道选用什么第三方库的性能最高，选用什么编程模型开发出来的工具效率最高。二、第三方库…
2022/7/24 14:30:43 人评论 次浏览 -
Kafka入门实战教程（7）：Kafka Streams
1 关于流处理 流处理平台（Streaming Systems）是处理无限数据集（Unbounded Dataset）的数据处理引擎，而流处理是与批处理（Batch Processing）相对应的。所谓的无线数据，指的是数据永远没有尽头。而流处理平台就是专门处理这种数据集的系统或框架。下图生动形象地展示…
2022/7/21 6:24:38 人评论 次浏览 -
java实现springboot集成exmq（mqtt协议）
1、application.yml配置 spring:mqtt:username: testpassword: qwerty123host-url: tcp://172.18.42.34:32016client-id: /dataProcessingTopicwfsubscribe-id: /dataProcessingtimeout: 100000keep-alive-interval: 100defaultTopic: $queue/+/dataProcessing 2、mqttcli…
2022/7/13 1:25:49 人评论 次浏览 -
mysql拆分字符串做条件查询
mysql拆分字符串作为查询条件 有个群友问一个问题这表的ancestors列存放的是所有的祖先节点,以,分隔 例如我查询dept_id为103的所有祖先节点,现在我只有一个dept_id该怎么查 然后我去网上找到这样一个神奇的sql,改改表名就成了下面的这样SELECTsubstring_index( substring…
2022/7/6 2:20:20 人评论 次浏览 -
我是如何将一个老系统的kafka消费者服务的性能提升近百倍的
☞☞☞ 我是如何将一个老系统的kafka消费者服务的性能提升近百倍的 ☜☜☜○○○○○○○☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝○○○○○○○○ 大家好，又见面了~ kafka作为一种高吞吐量的分布式发布订阅消息系统，在业务系统中被广泛的使用。如果问你，如何提高ka…
2022/7/5 23:20:57 人评论 次浏览 -
MySQL及SQL SERVER获取连续时间实例
--MySQL select (2022-05-05+interval(cast(mysql.help_topic.help_topic_id as signed)) day) as DAY from mysql.help_topic HAVING (DAY <= date_FORMAT(2022-07-05,%Y-%m-%d)) order by DAY --SQL Server select convert(varchar(10),dateadd(day,number,2022-05-0…
2022/6/29 2:20:13 人评论 次浏览 -
RocketMQ
转自 https://blog.csdn.net/qq_21040559/article/details/122703715 1 介绍RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。 1.1 RocketMQ 特点支持发布/订阅（Pub/Sub）和点对点（P2P）消息模型 …
2022/6/21 23:21:47 人评论 次浏览 -
Pulsar解决的问题
1.提供一个实时处理消息队列以及大规模数据流处理的平台 2.当前大多数的流处理平台，都无法简单的上云平台进行弹性伸缩扩展，比如Kafka，扩展node或者topic的分区，都要触发rebalance，rebalance期间是无法进行数据读写的。
2022/6/4 23:21:42 人评论 次浏览 -
Kafak入门
1. kafka介绍 1.1. 主要功能 根据官网的介绍，ApacheKafka是一个分布式流媒体平台，它主要有3种功能：1：It lets you publish and subscribe to streams of records.发布和订阅消息流，这个功能类似于消息队列，这也是kafka归类为消息队列框架的原因2：It l…
2022/4/22 23:45:54 人评论 次浏览 -
|NO.Z.00007|——————————|Deployment|——|Hadoop&OLAP数据库管理系统.v07|---------------------------------|ClickH
[BigDataHadoop：Hadoop&OLAP数据库管理系统.V07] [Deployment.OLAP数据库管理系统][|ClickHouse：ClickHouse链接kafka|]一、ClickHouse链接Kafka### --- ClickHouse链接Kafka：此引擎与 Apache Kafka 结合使用。~~~ # Kafka 特性： ~…
2022/4/17 19:42:39 人评论 次浏览 -
python之Kafka
1.安装kafka环境# 看这个地址 https://blog.csdn.net/github_38482082/article/details/82112641 # 你还需要装Java环境 # 测试启动如果启动成功，那么证明kafka启动成功 .\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties #启动kafka .\bin\wind…
2022/3/31 20:49:29 人评论 次浏览
