搜索结果
查询Tags标签： topic，共有 206条记录-
基于Flask框架的Web编程——topic 2
目录 Flask框架环境搭建安装虚拟环境创建虚拟环境激活虚拟环境退出虚拟环境指定python解释器 安装Flask开始flask操作Flask框架环境搭建Flask依赖外部的两个库：werkzeug（路由模块）和jinja2，这两个是Flask的核心。 虚拟环境的作用：在一台计算机开发多个不同的项目，需…
2022/3/21 22:58:56 人评论 次浏览 -
Kafka v2.3 快速入门与实践
消息队列应用场景：应用解耦、异步消息、流量削峰等问题，实现高性能、高可用、可伸缩和最终一致性架构。 Kafka是由LinkedIn开发的一个分布式的消息系统，可独立部署在单台服务器上，也可部署在多台服务器上构成集群。它提供了发布与订阅功能。用户可以发送数据到Kafka集…
2022/3/18 23:29:35 人评论 次浏览 -
kafka常用脚本
原文地址: kafka常用脚本 欢迎访问: 我的博客 引言 本文是转载的, 但是原文 在Kafka安装目录下 ($KAFKA_HOME/bin), 提供了很多内置的脚本供我们使用, 使用脚本可以测试 Kafka 的大多数功能, 下面我们就脚本的使用作出说明. 启动 broker bin/kafka-server-start.sh 脚本提…
2022/3/9 23:14:46 人评论 次浏览 -
Kafka宝典
Kafka 笔记内容取自尚硅谷Kafka3.0教程，以及《深入理解Kafka核心设计与实践原理》 内容还会不断充实~ 概述 定义 传统定义： Kafka是一个分布式的基于发布/订阅模式的消息队列（Message Queue），主要应用于大数据实时处理领域 最新定义： Kafka是一个开源的分布式事件流…
2022/2/28 6:25:51 人评论 次浏览 -
kafka
Kafka是为大数据而生的消息中间件，在数据采集、传输、存储的过程中发挥着举足轻重的作用。 优点： 性能卓越，单机写入TPS约在百万条/秒，最大的优点，就是吞吐量高。 时效性：ms级 可用性：非常高，kafka是分布式的，一个数据多个副本，少数机器宕机，不会丢失数据，不会…
2022/2/17 23:21:02 人评论 次浏览 -
一次Kafka内存泄露排查经过
现象： 2月11号数据： 2月14号数据： 2月15号数据： 可以看到newPartitionProducer持续增长，可定位到是kafka的问题。 最近增加的topic：ai_face_process_topic 2022.1.25上线到今天2022.2.15一共20天，只增长了701个视频，平均每天35个视频。 但这个topic有64个分区。…
2022/2/17 7:14:46 人评论 次浏览 -
生产者到topic
producer发布消息写入方式producer 采用 push 模式将消息发布到 broker，每条消息都被 append 到 patition 中，属于顺序写磁盘（顺序写磁盘效率比随机写内存要高，保障 kafka 吞吐率，关于磁盘顺序写入）。消息路由producer 发送消息到 broker 时，会根据分区算法选择将其…
2022/2/16 23:43:21 人评论 次浏览 -
PHP使用Kafka
PHP使用Kafka1.前言中文文档地址：https://kafka.apachecn.org/1.1定义Apache Kafka 是 一个分布式流处理平台1.2基本原理1.3名词解释名词BrokerTopicPartitionProducerConsumerConsumerGroup2.安装Java环境# 下载jdk1.8https://www.oracle.com/java/technologies/javase/…
2022/2/10 12:12:56 人评论 次浏览 -
Kafka 学习笔记
为什么使用消息队列？ 以用户下单购买商品的行为举例，在使用微服务架构时，我们需要调用多个服务。传统的调用方式是同步调用，这会存在一定的性能问题使用消息队列可以实现异步的通信方式，相比于同步的通信⽅式，异步的⽅式可以让上游快速成功，极大提高系统的吞吐量。…
2022/2/7 6:14:10 人评论 次浏览 -
【Kafka】03 Shell 操作
查看Kafka主题列表$KAFKA_HOME/bin/kafka-topics.sh \ --zookeeper centos7-02:2181,centos7-03:2181,centos7-04:2181 \ --list 创建一个主题（Topic）$KAFKA_HOME/bin/kafka-topics.sh \ --zookeeper centos7-02:2181,centos7-03:2181,centos7-04:2181 \ --create \ --…
2022/2/1 7:29:19 人评论 次浏览 -
全站最硬核 百万字强肝RocketMq源码 火热更新中~（八十六）延时队列
offset 在rocketMQ中，offset用来管理每个消息队列的不同消费组的消费进度。对offset的管理分为本地模式和远程模式，本地模式是以文本文件的形式存储在客户端，而远程模式是将数据保存到broker端，对应的数据结构分别为LocalFileOffsetStore和RemoteBrokerOffsetStore。 …
2022/1/30 11:04:17 人评论 次浏览 -
SpringBoot整合RocketMQ，顺序消息
目录 引言问题分析RocketMq顺序消息生产者消费者消费结果小结引言总有那么一种业务需求是要有先后顺序来执行问题分析 例：在A系统下了一个订单，需要推到B系统去生成订单和发货单，并且是要先生成订单再生成发货单，如果按正常情况去先发造成订单的消息到MQ，再发生成发货…
2022/1/25 6:05:54 人评论 次浏览 -
全站最硬核 百万字强肝RocketMq源码 火热更新中~（四十二）
如果资源路径包含namesapce，那么把namespace去掉 public static String wrapNamespace(String namespace, String resourceWithOutNamespace) {当然也有反向的，除了去掉resource中的namespace外，还有给resource包上namespace if (isRetryTopic(resourceWithOutNamespac…
2022/1/24 22:06:51 人评论 次浏览 -
FlinkSQL实践 -- 时态表/版本表
1. 背景 在FlinkSQL关联时，必然会涉及到维表，维表又可能是不断变化的（aka 时态表 或 版本表）。 版本表: 如果时态表中的记录可以追踪和并访问它的历史版本，这种表我们称之为版本表，来自数据库的 changelog 可以定义成版本表。 普通表: 如果时态表中的记录仅仅可以追…
2022/1/24 19:04:47 人评论 次浏览 -
【ROS学习笔记】4.玩转小海龟——ROS命令行工具
文章目录 1 回顾第一个小海龟程序2 查看系统中的计算图：rqt_graph3 rosnode显示话题列表：rosnode list查看节点信息：rosnode info 4 rostopic显示topic列表：rostopic list手动发布数据给topic 5 rosmsg查看消息数据结构 6 使用服务通信方式：rosservice查看服务列表：…
2022/1/12 23:06:57 人评论 次浏览
