1：下载kafka
代码语言：javascript复制wget https://archive.apache.org/dist/kafka/2.2.0/kafka_2.12-2.2.0.tgz
tar -zxvf kafka_2.12-2.2.0.tgz
cd kafka_2.12-2.2.0/2：启动服务 运行kafka需要使用zookeeper，所以你需要先启动zookeeper，如果你没有zookeeper，你可以使用kafka自带打包和配置好的zookeeper。启动命令如下：
代码语言：javascript复制> bin/zookeeper-server-start.sh config/zookeeper.properties
OpenJDK 64-Bit Server VM warning: If the number of processors is expected to increase from one, then you should configure the number of parallel GC threads appropriately using -XX:ParallelGCThreads=N启动kafka服务
代码语言：javascript复制bin/kafka-server-start.sh config/server.properties &等所有服务启动成功了，则表示kafka可以使用了。
3：使用kafka，创建一个主题（topic） 创建一个名为“test”的Topic，只有一个分区和一个备份：
代码语言：javascript复制bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test创建好之后，可以通过运行以下命令，查看已创建的topic信息：
代码语言：javascript复制bin/kafka-topics.sh --list --zookeeper localhost:2181
test4：发送消息 Kafka提供了一个命令行的工具，可以从输入文件或者命令行中读取消息并发送给Kafka集群。每一行是一条消息。 运行producer（生产者）,然后在控制台输入几条消息到服务器。
代码语言：javascript复制bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test5：消费消息 Kafka也提供了一个消费消息的命令行工具，将存储的信息输出出来。
代码语言：javascript复制bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning6：设置多个broker集群 到目前，我们只是单一的运行一个broker，线上一般都是多个broker。对于Kafka，一个broker仅仅只是一个集群的大小，所有让我们多设几个broker。
代码语言：javascript复制cp config/server.properties config/server-1.properties
cp config/server.properties config/server-2.properties现在编辑这些新建的文件，设置以下属性
代码语言：javascript复制config/server-1.properties:
broker.id=1
listeners=PLAINTEXT://:9093
log.dir=/tmp/kafka-logs-1
config/server-2.properties:
broker.id=2
listeners=PLAINTEXT://:9094
log.dir=/tmp/kafka-logs-2broker.id是集群中每个节点的唯一且永久的名称，我们修改端口和日志目录是因为我们现在在同一台机器上运行，我们要防止broker在同一端口上注册和覆盖对方的数据。
我们上面已经运行了zookeeper和刚才的一个kafka节点，所有我们只需要在启动2个新的kafka节点。
代码语言：javascript复制bin/kafka-server-start.sh config/server-1.properties &
bin/kafka-server-start.sh config/server-2.properties &现在，我们创建一个新topic，把备份设置为：3
代码语言：javascript复制bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic好了，现在我们已经有了一个集群了，我们怎么知道每个集群在做什么呢？运行命令“describe topics”
代码语言：javascript复制bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic
Topic:my-replicated-topic PartitionCount:1 ReplicationFactor:3 Configs:
Topic: my-replicated-topic Partition: 0 Leader: 1 Replicas: 1,2,0 Isr: 1,2,0输出解释：第一行是所有分区的摘要，其次，每一行提供一个分区信息，因为我们只有一个分区，所以只有一行。
“leader”：该节点负责该分区的所有的读和写，每个节点的leader都是随机选择的。 “replicas”：备份的节点列表，无论该节点是否是leader或者目前是否还活着，只是显示。 “isr”：“同步备份”的节点列表，也就是活着的节点并且正在同步leader。
