码迷,mamicode.com
首页 >  
搜索关键字:kafka    ( 4273个结果
kafka入门:简介、使用场景、设计原理、主要配置及集群搭建
问题导读: 1.zookeeper在kafka的作用是什么? 2.kafka中几乎不允许对消息进行“随机读写”的原因是什么? 3.kafka集群consumer和producer状态信息是如何保存的? 4.partitions设计的目的的根本原因是什么? 一、入门     1、简介     Kafka is a distribu...
分类:其他好文   时间:2016-06-02 14:39:21    阅读次数:215
Kafka Topic Partition Replica Assignment实现原理及资源隔离方案
本文共分为三个部分: Kafka Topic创建方式 Kafka Topic Partitions Assignment实现原理 Kafka资源隔离方案 1. Kafka Topic创建方式 Kafka Topic创建方式有以下两种表现形式: (1)创建Topic时直接指定Topic Partiti ...
分类:其他好文   时间:2016-06-01 21:25:37    阅读次数:746
(版本定制)第15课:Spark Streaming源码解读之No Receivers彻底思考
hu本期内容:1、Kafka解密背景:目前NoReceivers在企业中使用的越来越多,NoReceivers具有更强的控制度,语义一致性。NoReceivers是我们操作数据来源自然方式,操作数据来源使用一个封装器,且是RDD类型的。所以SparkStreaming就产生了自定义RDD–>KafkaRDD.源码分析:1、K..
分类:其他好文   时间:2016-06-01 06:59:16    阅读次数:288
第15课:Spark Streaming源码解读之No Receivers彻底思考
本期内容:DirectAccessKafka前面有几期我们讲了带Receiver的SparkStreaming应用的相关源码解读。但是现在开发SparkStreaming的应用越来越多的采用NoReceivers(DirectApproach)的方式,NoReceiver的方式的优势:1.更强的控制自由度2.语义一致性其实NoReceivers的方式更符合我..
分类:其他好文   时间:2016-05-31 19:16:59    阅读次数:247
消息列队组件的一些特性比较
RabbitMQ 基于AMQP实现,传统的messaging queue系统实现,基于Erlang。老牌MQ产品了。AMQP协议更多用在企业系统内,对数据一致性、稳定性和可靠性要求很高的场景,对性能和吞吐量还在其次。 Kafka linkedin开源的MQ系统,主要特点是基于Pull的模式来处理消息 ...
分类:其他好文   时间:2016-05-31 18:32:34    阅读次数:215
KIP-32 Add timestamps to Kafka message
通过KIP32,Kafka的每条消息都加进了时间戳,这个KIP在0.10.0.0被加入。 说到“时间”,先贴张图,娱乐一下(如果对星球大战系列电影不熟的话,请自动略过……) 这个KIP的文档在 KIP-32 - Add timestamps to Kafka message 下面贴一下这个KIP的关 ...
分类:其他好文   时间:2016-05-30 19:49:26    阅读次数:202
borker(0.9.0及1.0.0)配置
Kafka日志本身是由多个日志段组成(log segment)。一个日志是一个FileMessageSet,它包含了日志数据以及OffsetIndex对象,该对象使用位移来读取日志数据 * borker配置就是指配置server.properties文件 *最小配置通常情况下需要在减压缩kafka后,修改config/server.properties 配置文件中的以下两项log.dirs = k...
分类:其他好文   时间:2016-05-30 15:28:01    阅读次数:234
kafka-系列1
问题导读 1.Kafka独特设计在什么地方? 2.Kafka如何搭建及创建topic、发送消息、消费消息? 3.如何书写Kafka程序? 4.数据传输的事务定义有哪三种? 5.Kafka判断一个节点是否活着有哪两个条件? 6.producer是否直接将数据发送到broker的leader(主节点)? 7.Kafa consumer是否可以消费指定分区消息? 8.Kafka消息是...
分类:其他好文   时间:2016-05-30 14:41:12    阅读次数:302
Spark Streaming源码解读之No Receivers彻底思考
本期内容 : Direct Acess Kafka Spark Streaming接收数据现在支持的两种方式: 01、 Receiver的方式来接收数据,及输入数据的控制 02、 No Receiver的方式 以上两种方式中,No Receiver的方式更符合读取、操作数据的思路,Spark作为一个 ...
分类:其他好文   时间:2016-05-30 07:39:17    阅读次数:159
kafka理论
一、消息队列,简称MQ,message queue 生产者:生存数据写到kafka,持久化到硬盘。对同一个Topic来讲,生产者通常只有‘一个’(可以多并发)数据保存时常可以配置,默认保存七天。 消费者:从kafka里消费数据。对同一个Topic来讲,消费者会很多,根据业务需要。 kafka的消息分 ...
分类:其他好文   时间:2016-05-29 06:20:45    阅读次数:496
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!