首先安装一个zk。然后再安装kafka：
执⾏以下命令创建名为“test”的topic，这个topic只有⼀个partition，并且备份因⼦也设置为1：
然后在kafka节点下，执行如下命令：
./kafka-topics.sh --create --zookeeper 172.16.253.35:2181 --replicationfactor 1 --partitions 1 --topic test
含义：副本为1；分区为1；主题为test；
（1）、replicationfactor——副本；
（2）、partitions——分区；
（3）、topic——主题；
-------------------------------------------------------------------------------------------------------------------------------------------------
然后，查看当前kafka内有哪些topic，执行如下命令：
./kafka-topics.sh --list --zookeeper 172.16.253.35:2181
======================================================================================================
发送消息
kafka⾃带了⼀个producer命令客户端，可以从本地⽂件中读取内容，或者我们也可以以命令⾏中直接输⼊内容，并将这些内容以消息的形式发送到kafka集群中。
在默认情况下，每⼀个⾏会被当做成⼀个独⽴的消息。使⽤kafka的发送消息的客户端，指定发送到的kafka服务器地址和topic
./kafka-console-producer.sh --broker-list 172.16.253.38:9092 --topic test
=============================================================================================================================
消费消息
对于consumer， kafka同样也携带了⼀个命令⾏客户端，会将获取到内容在命令中进⾏输出， 默认是消费最新的消息。
使⽤kafka的消费者消息的客户端，从指定kafka服务器的指定topic中消费消息
------------------------------------------------------------------------------------------------------------------------------------------------------------------
⽅式⼀：从最后⼀条消息的偏移量+1开始消费
./kafka-console-consumer.sh --bootstrap-server 172.16.253.38:9092 --topic test
----------------------------------------------------------------------------------------------------------------------------------------------------------------------
⽅式⼆：从头开始消费
./kafka-console-consumer.sh --bootstrap-server 172.16.253.38:9092 --from-beginning --topic test
===============================================================================================================
⼏个注意点：
（1）、消息会被存储
（2）、消息是顺序存储
（3）、消息是有偏移量的
（4）、消费时可以指明偏移量进⾏消费
=====================================================================================================
