码迷,mamicode.com
首页 >  
搜索关键字:kafka 扩容 topic empty    ( 15636个结果
OpenStack源码分析——Nova-Scheduler
一、服务启动Nova-scheduler服务的启动入口脚本是cmd包下的scheduler.py,其主要监听来自于消息队列中topic=scheduler(可配置)的消息。在服务启动过程中,其将初始化一个SchedulerManager实例作为该服务的Handler,来处理接受到的消息请求。同时,N...
分类:其他好文   时间:2014-07-06 20:45:27    阅读次数:200
RabbitMQ之Topics(多规则路由)
Exchange中基于direct类型无法基于多种规则进行路由。例如分析syslog日志,不仅需要基于severity(info/warning/critical/error)进行路由,还需要基于auth、cron或者kernal模式进行路由。Topic exchange可以满足这种需求。Topic...
分类:其他好文   时间:2014-07-06 17:35:31    阅读次数:366
leetcode--Sudoku Solver
Write a program to solve a Sudoku puzzle by filling the empty cells.Empty cells are indicated by the character'.'.You may assume that there will be on...
分类:其他好文   时间:2014-07-06 16:07:23    阅读次数:204
linux扩展lvm磁盘
env:centos 6.5 x64 hyper-v虚拟机这个方法可以在当前运行的系统中扩展root磁盘详细步骤之前想创建的一个虚拟机的磁盘空间不够用了,所以想扩容一下磁盘。正好使用的时候是lvm磁盘,可以支持扩容。格式化一个新的分区或者磁盘Command (m for help): n ## ne...
分类:系统相关   时间:2014-07-06 14:53:12    阅读次数:277
队列queue
队列queue也是一种线性结构,我们可以再其两端进行操作,它是一种属于先进先出的结构(FIFO)。 数据在只能在队尾进入,且只能在队首出去。 队列与栈差不多,基本操作如下: 1.queue::size() 2.queue::empty() 3.queue::push(typename ...
分类:其他好文   时间:2014-07-06 14:26:25    阅读次数:189
stack
栈是一种线性的结构,先进后出(FILO),我们只能在栈的一端对数据进行操作,数据的插入与删除只能在栈的一端进行。 在STL中的栈stack一共只有5中操作。 1.stack::empty() 2.stack::size() 3.stack::push(typename t) 4.sta...
分类:其他好文   时间:2014-07-06 14:24:34    阅读次数:183
leetcode--Scramble String
Given a strings1, we may represent it as a binary tree by partitioning it to two non-empty substrings recursively.Below is one possible representation...
分类:其他好文   时间:2014-07-06 13:57:54    阅读次数:155
vector
vector是我使用比较多的一个容器,它相当于一个动态的数组,在STL中给他提供了很多接口,简单易懂,接下来简单的演示一下它是如何使用的。 我一般使用的一些函数接口有size(),reserve(),empty(),begin(),end(),push_back(),find(),erase(...
分类:其他好文   时间:2014-07-05 22:27:43    阅读次数:276
post 抓取
function curlBy($url, $data=array()){ $ch = curl_init(); if(!empty($data)){ if (is_array($data) && $data) { $formdata = http_build_query($data); curl....
分类:其他好文   时间:2014-07-05 17:10:24    阅读次数:228
一个轻客户端,多语言支持,去中心化,自动负载,可扩展的实时数据写服务的实现方案讨论
背景是设计一个实时数据接入的模块,负责接收客户端的实时数据写入(如日志流,点击流),数据支持直接下沉到HBase上(后续提供HBase上的查询),或先持久化到Kafka里,方便后续进行一些计算和处理,再下沉到文件系统或做别的输出。 在设计中,对于客户端和服务端有这么些目标。 客户端需要支持多语言(Java,C++),做得尽量轻量级,只要连上服务端的ip:port,以RPC的形式调用简单的write就可以把数据写出去。客户端不承担任何逻辑的处理,服务端的负载均衡对客户端是透明的。 服务端想要做的是一个去中心...
分类:其他好文   时间:2014-07-04 08:59:19    阅读次数:552
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!