码迷,mamicode.com
首页 >  
搜索关键字:kafka 基本概念    ( 13632个结果
和我一起学python,基本概念 (life is short ,we need python)
作者:tobecrazy 出处:http://www.cnblogs.com/tobecrazy 欢迎转载,转载请注明出处。thank you!基本概念 : 常量: 常量名全部大写,如PI 变量: python没有变量类型,也不必声明,直接赋值即可.变量可以是数字,字符串,布尔值(T...
分类:编程语言   时间:2014-07-07 18:25:55    阅读次数:314
践踏堆栈-缓冲区溢出漏洞
践踏堆栈-缓冲区溢出漏洞 打算写这篇文章是因为在网上看过一篇论文,讲了缓冲区溢出破坏堆栈来执行恶意程序的漏洞。该论文请见参考资料1。这篇文章会涉及一些汇编的基础知识,以及虚拟内存的一些基本概念等。当然用来调试程序的系统是linux,工具是gcc。很久没有看过汇编和C语言了,错漏之处,还请指正。 1.概要 文章标题有提到堆栈和缓冲区,那么就先来探讨下这几个名词的定义。这里的缓冲区,指的就是计算...
分类:其他好文   时间:2014-06-30 10:22:25    阅读次数:176
VxWorks6.6 pcPentium BSP 使用说明(一):基本概念
“VxWorks6.6 BSP 使用说明”将发布pcPentium和idp945两个系列的BSP的使用说明。每个系列约5篇文章。之后还将发布由这两个官方提供的BSP的实战移植方法。 本说明适用范围 pcPentium/2/3/4 - 386/486 和 Pentium/2/3/4 引言 该参考文档提供运行pcPentium,pcPentium2,pcPentium3和pcPen...
分类:其他好文   时间:2014-06-30 08:58:17    阅读次数:281
apache kafka迁移与扩容工具用法
本篇blog教你如果使用kafka工具进行迁移和扩容相关topic。...
分类:其他好文   时间:2014-06-30 00:37:22    阅读次数:337
Jafka源代码分析——网络架构
在kafka中,每一个broker都是一个服务器。按照一般理解,服务器就是一个SocketServer,其不断接收用户的请求并进行处理。在Java中进行网络连接有两种方式一种为阻塞模式一种为非阻塞模式。Jafka采用非阻塞模式进行网络通讯。在Java的非阻塞模式中,建立socket server的一般流程如下: 1.启动ServerSocketChannel并将其绑定到特定的端口。 2.将Se...
分类:其他好文   时间:2014-06-28 09:25:54    阅读次数:235
Jafka源代码分析——Processor
Jafka Acceptor接收到客户端请求并建立连接后,Acceptor会将Socket连接交给Processor进行处理。Processor通过以下的处理步骤进行客户端请求的处理: 1. 读取客户端请求。 2. 根据客户端请求类型的不同,调用相应的处理函数进行处理。 Processor读取客户端请求是一个比较有意思的事情,需要考虑两个方面的事情:第一,请求规则(Processor需要按照...
分类:其他好文   时间:2014-06-28 09:25:18    阅读次数:278
Jafka源代码分析——LogManager
在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
RabbitMQ学习及实践2---介绍及简单Java实现
一,基本概念MQ是消费-生产者模型的一个典型的代表,一端往消息队列中不断写入消息,而另一端则可以读取或者订阅队列中的消息。MQ和JMS类似,但不同的是JMS是SUNJAVA消息中间件服务的一个标准和API定义,而MQ则是遵循了AMQP协议的具体实现和产品。RabbitMQ是一个在AMQP基础上完..
分类:编程语言   时间:2014-06-28 00:03:06    阅读次数:3862
Jafka源代码分析——随笔
Kafka是一个分布式的消息中间件,可以粗略的将其划分为三部分:Producer、Broker和Consumer。其中,Producer负责产生消息并负责将消息发送给Kafka;Broker可以简单的理解为Kafka集群中的每一台机器,其负责完成消息队列的主要功能(接收消息、消息的持久化存储、为Consumer提供消息、消息清理.....);Consumer从Broker获取消息并进行后续的操作。...
分类:其他好文   时间:2014-06-27 23:55:13    阅读次数:387
flume-ng1.4 安装配置
flume-ng1.4安装配置记录一下flume-ng的安装配置三个基本概念source:数据源channel:数据传输通道sink:数据目的地,如存储在hdfs配置:flume.conf#defineagent1.sources=source1agent1.channels=channel1agent1.sinks=sink1#agent1.sources.source1.type=spooldiragent1.sour..
分类:其他好文   时间:2014-06-27 06:41:36    阅读次数:221
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!