码迷,mamicode.com
首页 >  
搜索关键字:kafka 扩容 topic empty    ( 15636个结果
[2021 spring] CS61A Lab 6: Nonlocal, Mutability, Iterators and Generators
[2021 spring] CS61A Lab 6: Nonlocal, Mutability, Iterators and Generators ...
分类:编程语言   时间:2021-07-02 16:21:32    阅读次数:0
CentOS7.8 扩容
1、查看系统分区的详细情况 fdisk -l 2、对磁盘进行分区 #需要注意的是/dev/sdb要根据第一步查看的路径来设置,挂载的路径实际操作的时候略有不同 fdisk /dev/sdb 创建新分区 # 1 选择n创建 ? Command (m for help): n # 2 创建分区 Part ...
分类:其他好文   时间:2021-07-02 16:19:29    阅读次数:0
同程旅行基于 RocketMQ 高可用架构实践
?简介: 我们在几年前决定引入 MQ 时,市场上已经有不少成熟的解决方案,比如 RabbitMQ , ActiveMQ,NSQ,Kafka 等。考虑到稳定性、维护成本、公司技术栈等因素,我们选择了 RocketMQ。 ? 背景介绍 ? 为何选择 RocketMQ ? 我们在几年前决定引入 MQ 时, ...
分类:其他好文   时间:2021-07-02 16:09:00    阅读次数:0
Kafka入门(一)-基础概念
https://kafka.apachecn.org/intro.html 一、kafka能做什么? 构造实时流数据管道,它可以在系统或应用之间可靠地获取数据。 (相当于message queue) 构建实时流式应用程序,对这些流数据进行转换或者影响。 (就是流处理,通过kafka stream t ...
分类:其他好文   时间:2021-07-01 17:05:23    阅读次数:0
kafka与celery的区别
kafka它们属于消息队列;celery它们属于任务队列。 消息队列和任务队列,最大的不同之处就在于理念的不同 -- 消息队列传递的是“消息”,任务队列传递的是“任务”。 我们可以放到具体的应用场景上: 消息队列用来快速消费队列中的消息。比如日志处理场景,我们需要把不同服务器上的日志合并到一起,这时 ...
分类:其他好文   时间:2021-06-30 18:33:26    阅读次数:0
MGR由5.7.24升级至8.0.20记录
升级原因 5.7版本的MGR多主模式存在比较严重的问题,无法预知和监控的认证故障,会导致部分行数据无法修改,故急需升级至8.0 升级流程 原集群有5个节点,首先扩容一个5.7.24的节点,将其升级为8.0.20的实例(注意参数的变化,如果数据量比较小,可以采用导出导入的方式,由于mysql8升级非常 ...
分类:其他好文   时间:2021-06-30 17:59:42    阅读次数:0
python-- kafka(一): kafka 安装和查询
kafka 应用数据读取理论生产者和消费者 生产者:生产数据 消费者:消费生产者产生的数据 对应关系:一个任务可以有多个分组,可以对应多个消费者,但消费者数量不能大于生产者分组数量,多余的也是无用的。(多对多的中的一对一关系) 特性:kafka只需写入一次,可以支持任意多的应用读取全部数据,如果应用 ...
分类:编程语言   时间:2021-06-30 17:51:24    阅读次数:0
python --kakfa(三):kafka模块生产和消费数据
文章目录一、kafka是什么?二、使用步骤1. 安装1.引入库2.消费端:读取数据3.发送端:发送数据总结一、kafka是什么?kafka 是一个分布式流式计算平台。而在大部分企业开发人员中,都是把 kafka 当成消息系统使用,即它是一个分布式消息队列,很少会使用 kafka 的流式计算。它有四个 ...
分类:编程语言   时间:2021-06-30 17:50:03    阅读次数:0
并发编程-ConcurrentHashMap(二)
并发编程-ConcurrentHashMap(二) 昨天说到扩容前面的准备工作,和一系列的判断,其中我觉得设计精妙的就是他的那个【高低位扩容】,精巧的使用了二进制,从某种层面讲,提升了性能,因为二进制的那个变量的存储,就相同于一个容器,如果不使用它,那肯定要new出一个容器进行存储,这就会占用内存。 ...
分类:其他好文   时间:2021-06-30 17:32:02    阅读次数:0
每日温度
https://leetcode-cn.com/problems/daily-temperatures/ 思路1: 使用单调递减栈 public int[] dailyTemperatures(int[] T) { if (T == null || T.length == 0) return nul ...
分类:其他好文   时间:2021-06-28 19:54:53    阅读次数:0
15636条   上一页 1 2 3 4 ... 1564 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!