前言：最近公司开始要研究大数据的消息记录，于是开始研究kafka。

市面上kafka的书很少，有的也版本比较落后，于是仗着自己英文还不错，上官网直接学习。 ^_^

 

1. 开始 - 基本概念

学习一样东西，我们首先要知道它是什么。

那么kafka是什么呢？

照官网的解释: 

Apache Kafka™ is a distributed streaming platform. 

(Kafka是一个分布式的流式数据平台。)

照着官网的解释，kafka拥有以下3项主要能力：

1) 能够在流记录上进行发布和订阅，类似于消息队列了。

2) 能够容错存储流记录。

3) 能够处理流记录。

 

那么，接下来又要问了，我们用kafka的好处是什么呢？

主要有以下2点好处：

1) 在系统或者应用之间可以构建可依赖的实时的流数据管道。

2)  可以构建实时的处理流数据的系统。

 

2. 核心概念

* kafka以集群的方式运行在一台或多态服务器上。

* kafka集群根据topic(主题)对存储的流记录进行分类。

* 每条流记录包含一个键值对和一个时间戳。

 

3. 核心API

* Producer(生产者) API 允许应用程序发布流记录到一个或多个kafka主题。

* Consumer(消费者) API允许应用程序订阅一个或多个kafka主题，从而对这些主题下的流数据进行处理。

* Streams(流) API则负责高效地处理各个主题下的流记录。

* Connector(连接器) API允许构建可重用的生产者或消费者，并且让他们和现有的系统进行对接。

  （举个例子：一个连接到关系型数据库的连接器可以捕捉表格的每次改变）

 

 

4. 主题和日志

一个主题可以被多个消费者订阅。

 kafka的每个主题是以分区日志的形式维护的。

日志中的每个分区分布在集群中的各个服务器上。

有一台服务器扮演leader(头领)的角色，而其余的服务器则是followers(跟随者)。

 

5. 生产者(Producer)和消费者(Consumer)

 

上图是2台服务器的kafka集群带了4个分区(P0 - P3)， 2组Consumer订阅Producer发布的主题消息。

 

6. 安装和启动

1）下载kafka源码

https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.2.0/kafka_2.11-0.10.2.0.tgz

> tar -xzf kafka_2.11-0.10.2.0.tgz
> cd kafka_2.11-0.10.2.0

 

2) 启动服务器

由于kafka使用zookeeper来管理集群，所以你先需要启动zookeeper。

如果你没有安装zookeeper,你可以是用户kafka的内置脚本启动一个单节点的zookeeper实例。
  2-1) 启动单节点zookeeper实例：

  > bin/zookeeper-server-start.sh config/zookeeper.properties

  2-2) 启动kafka server:

  > bin/kafka-server-start.sh config/server.properties

   2-3) 创建topic(主题)

   > bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

   2-4) 使用list命令查看所有主题

   > bin/kafka-topics.sh --list --zookeeper localhost:2181

     显示结果:  test

 

7. 发送消息

# 运行生产者脚本，并向刚刚创建的test主题发送一些消息

> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

你可以打一些字，如下:

哈哈哈

嘿嘿，你好啊

 

8. 接收消息

# 运行消费者脚本，从test主题订阅消息

> bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

  收到消息：

  哈哈哈

  嘿嘿，你好啊

 

我们以上演示需要开启4个控制台，效果如下：

 

 

好了，第一次笔记到此结束，后续会继续阅读学习。 ^_^