kafka 在windows 平台的搭建和简单实用_real-time streaming applications that transform or

1.       kafka介绍

 

1.1.       主要功能

根据官网的介绍，ApacheKafka®是一个分布式流媒体平台，它主要有3种功能：

　　1：It lets you publish and subscribe to streams of records.发布和订阅消息流，这个功能类似于消息队列，这也是kafka归类为消息队列框架的原因

　　2：It lets you store streams of records in a fault-tolerant way.以容错的方式记录消息流，kafka以文件的方式来存储消息流

　　3：It lets you process streams of records as they occur.可以再消息发布的时候进行处理

1.2.       使用场景

1：Building real-time streaming data pipelines that reliably get data between systems or applications.在系统或应用程序之间构建可靠的用于传输实时数据的管道，消息队列功能

2：Building real-time streaming applications that transform or react to the streams of data。构建实时的流数据处理程序来变换或处理数据流，数据处理功能

 

1.3.       详细介绍

Kafka目前主要作为一个分布式的发布订阅式的消息系统使用，下面简单介绍一下kafka的基本机制

　　1.3.1 消息传输流程

　Producer即生产者，向Kafka集群发送消息，在发送消息之前，会对消息进行分类，即Topic，上图展示了两个producer发送了分类为topic1的消息，另外一个发送了topic2的消息。

　　　　Topic即主题，通过对消息指定主题可以将消息分类，消费者可以只关注自己需要的Topic中的消息

　　　　Consumer即消费者，消费者通过与kafka集群建立长连接的方式，不断地从集群中拉取消息，然后可以对这些消息进行处理。

　　　　从上图中就可以看出同一个Topic下的消费者和生产者的数量并不是对应的。

　　1.3.2 kafka服务器消息存储策略

　　谈到kafka的存储，就不得不提到分区，即partitions，创建一个topic时，同时可以指定分区数目，分区数越多，其吞吐量也越大，但是需要的资源也越多，同时也会导致更高的不可用性，kafka在接收到生产者发送的消息之后，会根据均衡策略将消息存储到不同的分区中。

在每个分区中，消息以顺序存储，最晚接收的的消息会最后被消费。

　　1.3.3 与生产者的交互

　生产者在向kafka集群发送消息的时候，可以通过指定分区来发送到指定的分区中

　　　　也可以通过指定均衡策略来将消息发送到不同的分区中

　　　　如果不指定，就会采用默认的随机均衡策略，将消息随机的存储到不同的分区中

　　1.3.4  与消费者的交互

在消费者消费消息时，kafka使用offset来记录当前消费的位置

　　　　在kafka的设计中，可以有多个不同的group来同时消费同一个topic下的消息，如图，我们有两个不同的group同时消费，他们的的消费的记录位置offset各不相同，不互相干扰。

　　　　对于一个group而言，消费者的数量不应该多余分区的数量，因为在一个group中，每个分区至多只能绑定到一个消费者上，即一个消费者可以消费多个分区，一个分区只能给一个消费者消费

　　　　因此，若一个group中的消费者数量大于分区数量的话，多余的消费者将不会收到任何消息。

2.       Kafka安装与使用

 

2.1.       下载

　　你可以在kafka官网 http://kafka.apache.org/downloads下载到最新的kafka安装包，选择下载二进制版本的tgz文件，根据网络状态可能需要fq，这里我们选择的版本是0.11.0.1，目前的最新版

一、安装

      1、kafka 需要java环境；

      2、kafka 最新版本内置了 zookeeper，所以不需要安装zookeeper；

      3、下载kafka最新版本，点击下载，因为下载的是tgz文件，所以不需要安装，解压到相应的地方就可以了。

      4、bin 目录下放的是启动kafka的文件，conf目录下放的是kafka的各种配置文件。

二、运行

      简单demo测试，不需要修改任何配置文件，只需要知道 zookeeper的默认端口是2181，生产者的默认端口是9092。

      (可在conf/producer.properties和conf/zookeeper.properties下进行修改)

      1、启动zookeeper

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

2、启动kafka

bin\windows\kafka-server-start.bat config\server.properties

 3、创建主题topic，topic = test

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

-- 查看创建的topic

bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

 4、启动生产者 producer

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

启动生产者之后进入编辑页面，发送了 "nihao"，

       5、启动消费者 customer

bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic demo --from-beginning

当消费者启动之后，收到了之前生产者发送的 “nihao”。