码迷,mamicode.com
首页 >  
搜索关键字:kafka 扩容 topic empty    ( 15636个结果
栈在括号匹配中的应用
一. 算法思想 二. 代码实现 eg: [ ( [ ] [ ] ) ] 1.栈的括号匹配算法 int MatchBracket()//栈的括号匹配算法 { Stack S=InitStack(); ElemType ch; char arr[8]={'[','(','[',']','[',']',' ...
分类:其他好文   时间:2020-07-01 12:46:40    阅读次数:59
Flume简介
Kafka在实际的开发之中的确可以处理千万级别的数据,但是现在有一个问题,这些数据从哪里来呢?Kafka产生的初衷是进行数据的收集以及合理的消费,但是这些实际之中的数据我们应该如何获取,我们该用什么样的方式来获取,而且最关键的是,如果现在是一个已经成型的系统(SSH、SSM、Spring),那么这个 ...
分类:Web程序   时间:2020-07-01 12:37:05    阅读次数:61
用redis实现消息队列(实时消费+ack机制)
消息队列 首先做简单的引入。 MQ主要是用来: 解耦应用、 异步化消息 流量削峰填谷 目前使用的较多的有ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ等。网上的资源对各种情况都有详细的解释,在此不做过多赘述。本文仅介绍如何使用Redis实现轻量级MQ的过 ...
分类:其他好文   时间:2020-07-01 11:03:49    阅读次数:91
阿里架构师亲授:Kafka和RocketMQ的消息复制实现的差异点在哪?
本文已收录GitHub,更有互联网大厂面试真题,面试攻略,高效学习资料等众所周知,消息队列在收发两端,主要是依靠业务代码,配合请求确认的机制,来保证消息不会丢失的。而在服务端,一般采用持久化和复制的方式来保证不丢消息。把消息复制到多个节点上,不仅可以解决丢消息的问题,还可以保证消息服务的高可用。即使某一个节点宕机了,还可以继续使用其他节点来收发消息。所以大部分生产系统,都会把消息队列配置成集群模式
分类:其他好文   时间:2020-07-01 09:56:57    阅读次数:58
查找某个时间段生成的文件
需要找到某天(例如2020-07-1)以及这之后生成的空文件。那么这个要怎么处理呢?这个当然是用find命令来解决。如下所示, -mtime -5表示查找距现在5*24H内修改过的文件 -type f表示查找文件 -type f -empty表示空文件 由于需要以显示修改时间等文件信息,所以使用-e ...
分类:其他好文   时间:2020-07-01 09:52:01    阅读次数:62
Linux入门
Linux概述 消息对列(Kafka、RabbitMQ、RockeetMQ),缓存(Redis),搜索引擎(ES) 集群分布式(需要购买多台服务器,如果没服务器我们就只能使用虚拟机) 我们为什么要学Linux Linux的几个优点 免费(这个是大多数人的喜欢的吧) 很多软件原生是在Linux运行的, ...
分类:系统相关   时间:2020-07-01 09:24:00    阅读次数:122
PHP empty() 函数
empty() 函数用于检查一个变量是否为空。 empty() 判断一个变量是否被认为是空的。当一个变量并不存在,或者它的值等同于 FALSE,那么它会被认为不存在。如果变量不存在的话,empty()并不会产生警告。 返回值 当 var 存在,并且是一个非空非零的值时返回 FALSE 否则返回 TR ...
分类:Web程序   时间:2020-06-30 20:18:42    阅读次数:239
Deque双端队列
实现类:ArrayDeque和LinkedList 作用:Deque既可以做栈使用也可以做队列使用; 缺点:Deque违背了单一职责性原则 ArrayDeque: ArrayDeque是Deque接口的一种具体实现,是依赖于可变数组来实现的。ArrayDeque 没有容量限制,可根据需求自动进行扩容 ...
分类:其他好文   时间:2020-06-30 17:27:23    阅读次数:61
分区策略
分区的原因 方便在集群中扩展 可以提高并发 生产者分区原则 有partition,直接用 有key,用key.hash%partition.length 无,随机生成整数M,用n*M%partition.length ProducerRecord(String topic,int partition ...
分类:其他好文   时间:2020-06-30 13:06:23    阅读次数:51
SpringBoot开发案例之整合Kafka实现消息队列
本文代码使用的是Spring Boot 2.1.1.RELEASE 版本 <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version ...
分类:编程语言   时间:2020-06-30 13:00:18    阅读次数:51
15636条   上一页 1 ... 76 77 78 79 80 ... 1564 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!