在Kafka中，LogManager负责管理broker上所有的Log（每一个topic-partition为一个Log）。通过阅读源代码可知其具体完成的功能如下：
1. 按照预设规则对消息队列进行清理。
2. 按照预设规则对消息队列进行持久化（flush操作）。
3. 连接ZooKeeper进行broker、topic、partition相关的ZooKeeper操作。
4. 管理brok...
分类：
其他好文 时间：
2014-06-28 08:25:21
阅读次数：
208
Kafka是一个分布式的消息中间件，可以粗略的将其划分为三部分：Producer、Broker和Consumer。其中，Producer负责产生消息并负责将消息发送给Kafka；Broker可以简单的理解为Kafka集群中的每一台机器，其负责完成消息队列的主要功能（接收消息、消息的持久化存储、为Consumer提供消息、消息清理.....)；Consumer从Broker获取消息并进行后续的操作。...
分类：
其他好文 时间：
2014-06-27 23:55:13
阅读次数：
387
假设栈的输入序列为1234，判断以下4123，2431是否合法。 针对2431： 先让1进队，再让2进队列，让2弹出，让3入，让4入，最后依次弹出，则结果就是2431 针对4123： 要让4出队，必须先让123都入队，那么4接下来的出队顺序就应该是3，而不是1，所以错误。注： 1、必须保存入队...
分类：
其他好文 时间：
2014-06-27 14:58:09
阅读次数：
175
Linux下的CPU负载： 指的是一段时间内任务队列的长度，通俗的讲，就是一段时间内一共有多少任务在使用或等待使用CPU。通常通过有3个数值，分别代表1，5，15钟内的平均CPU负载，越小越好。CPU负载与CPU利用率不是同一个概念。虽然CPU负载表示当前系统还有多少个任务等待处理，而CPU利用则....
分类：
系统相关 时间：
2014-06-27 14:00:31
阅读次数：
219
说明：本文全文转载而来，原文链接：http://www.cppblog.com/wanghaiguang/archive/2012/06/05/177644.htmlC++ Queues(队列)C++队列是一种容器适配器，它给予程序员一种先进先出(FIFO)的数据结构。1.back() 返回一个引用...
分类：
编程语言 时间：
2014-06-27 11:17:33
阅读次数：
345
Re'entrantLock lock = new ReentrantLock(fair);
Condition
notEmpty = lock.newCondition(); //返回内部类 AbstractQueuedSyncronizer.ConditionObject
各自维护了两个队列.一个是阻塞同步队列 syncQueue 双向队列,一个是条件等待队列....
分类：
数据库 时间：
2014-06-27 09:10:37
阅读次数：
505
分析：
还是二叉树遍历模板的改造问题，对于二叉搜索树，中序遍历的结果是有顺序的。题目的要求无非是将中序遍历的结点访问结果链接起来，至于双向链表，通过复用树结点的left 和 right 指针就可以完成。最直接的就是我们可以把中序遍历中访问到的每个结点都放入到个队列里，然后将队列的元素链接起来，但是题目不允许用额外的空间。
想想中心遍历，遍历顺序是 左 --根---右，那么中序遍历的第一个访问结...
分类：
其他好文 时间：
2014-06-27 07:56:13
阅读次数：
341
实现优先队列结构主要是通过堆完成，主要有：二叉堆、d堆、左式堆、斜堆、二项堆、斐波那契堆、pairing 堆等。1. 二叉堆1.1. 定义完全二叉树，根最小。存储时使用层序。1.2. 操作(1). insert（上滤）插入末尾 26，不断向上比较，大于26则交换位置，小于则停止。(2). delet...
分类：
其他好文 时间：
2014-06-27 00:53:45
阅读次数：
369
Log4cpp是一个开源的C++类库，它提供了在C++程序中使用日志和跟踪调试的功能。使用log4cpp，能够非常便利地将日志或者跟踪调试信息写入字符流、内存字符串队列、文件、回滚文件、调试器、Windows日志、本地syslog和远程syslogserver中。1、Log4cpp简单介绍 L...
分类：
其他好文 时间：
2014-06-26 16:18:55
阅读次数：
253
