将向 Kafka topic 发布消息的程序成为 producers.将预订 topics 并消费消息的程序成为 consumer.Kafka 以集群的方式运行，可以由一个或多个服务组成，每个服务叫做一个 broker.producers 通过网络将消息发

kafka存储原理：kafka磁盘比内存块。kafka中topic为什么要实现分区：

12月6日下午运维反馈说，某个主题的一个分区消费积压，由于这个主题非常重要，且已经有用户投诉所以运维很紧张，紧急打印堆栈并Dump堆内存后，就重启了这台机器。通过这个线程上下文信息看到了SQL语句，这个SQL语句是查询某个表且两个查询字段也已经建立了索引，

　　kafka是LinkedIn开发并开源的一个分布式MQ系统，现在是Apache的一个孵化项目。在它的主页描述kafka为一个高吞吐量的分布式MQ。Kafka仅仅由7000行Scala编写，据了解，Kafka每秒可以生产约25万消息，每秒处理55万消息。

Apache顶级项目介绍系列－1，我们从Kafka说起。流行 ＋ 名字cool。Kafka官网是见过比较简单，直叙的网站，“kafka是一个高吞吐的分布式的消息系统”。Kafka最初起家于LinkedIn，当时原本作为linkedin用来管理活动流和运营数

前言: kafka是一个轻量级的/分布式的/具备replication能力的日志采集组件,通常被集成到应用系统中,收集"用户行为日志"等,并可以使用各种消费终端将消息转存到HDFS等其他结构化数据存储系统中.因为日志消息通常为文本数据,

kafka作为分布式日志收集或系统监控服务，我们有必要在合适的场合使用它。kafka的部署包括zookeeper环境/kafka环境，同时还需要进行一些配置操作.接下来介绍如何使用kafka.我们使用3个zookeeper实例构建zk集群，使用2个kafk

Confluent联合创始人兼CEO Jay Kreps发表了一篇博文，给出了Kafka的真正定位——它不只是个消息系统，它还是个存储系统，而它的终极目标是要让流式处理成为现代企业的主流开发范式。以下内容翻译自作者的博文，查看原文It’s Okay To

Apache Kafka是分布式发布-订阅消息系统。它最初由LinkedIn公司开发，之后成为Apache项目的一部分。Kafka是一种快速、可扩展的、设计内在就是分布式的，分区的和可复制的提交日志服务。现在很多开源分布式系统，例如Flume，Storm，

kafka是一款分布式消息发布和订阅的系统，具有高性能和高吞吐率。更多说明请自行了解，直接进入主题。2 cd kafka_2.10-0.10.1.0/bin 启动和停止命令等。　　创建一个名为“test”的Topic，只有一个分区和一个备份：bin/kaf

Topic在逻辑上可以被认为是一个管道，每条生产/消费都必须指明Topic，也就是指定这条消息应该在哪条管道进行传输。为了使得Kafka的吞吐率可以线性提高，物理上把Topic分成一个或多个Partition，每个Partition在物理上对应一个文件夹，

Kafka是目前非常流行的消息队列中间件，常用于做普通的消息队列、网站的活性数据分析、日志的搜集。概念介绍在Kafka中消息队列分为三种角色:. consumer，即消费者，负责读取使用broker中的分区。producerKafka系统中的生产者，用于产

Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。这种动作是在现代网络上的许多社会功能的一个关键因素。这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。Kafka的目的是通过Hadoop的并行加载机

dataDir,clientPort的意义显而易见，就不用说了，对于maxClientCnxns选项，如果不设置或者设置为0，则每个ip连接zookeeper时的连接数没有限制。需要注意的是，设置maxClientCnxns的值时需要把kafka serv