一，下载

http://kafka.apache.org/downloads
kafka_2.12-2.3.0
https://archive.apache.org/dist/kafka/2.3.0/kafka_2.12-2.3.0.tgz
前面2.12表示的是scala开发语言的版本，后面的2.3.0才是kafka的版本。下载之后，解压到一个测试用目录，然后进入这个目录。
后面的演示，都是基于kafka项目的根目录。

二，运行zookeeper

使用内置kafka，提供协调服务。

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

看到如下输出，表示zk安装成功：

[2020-10-14 11:13:31,953] INFO tickTime set to 3000 (org.apache.zookeeper.server.ZooKeeperServer)
[2020-10-14 11:13:31,953] INFO minSessionTimeout set to -1 (org.apache.zookeeper.server.ZooKeeperServer)
[2020-10-14 11:13:31,953] INFO maxSessionTimeout set to -1 (org.apache.zookeeper.server.ZooKeeperServer)
[2020-10-14 11:13:31,971] INFO Using org.apache.zookeeper.server.NIOServerCnxnFactory as server connection factory (org.apache.zookeeper.server.ServerCnxnFactory)
[2020-10-14 11:13:31,981] INFO binding to port 0.0.0.0/0.0.0.0:2181 (org.apache.zookeeper.server.NIOServerCnxnFactory)

三，运行kafka

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

看到如下输出，表示运行成功

[2020-10-14 11:15:03,479] INFO Kafka version: 2.3.0 (org.apache.kafka.common.utils.AppInfoParser)
[2020-10-14 11:15:03,479] INFO Kafka commitId: fc1aaa116b661c8a (org.apache.kafka.common.utils.AppInfoParser)
[2020-10-14 11:15:03,480] INFO Kafka startTimeMs: 1602645303475 (org.apache.kafka.common.utils.AppInfoParser)
[2020-10-14 11:15:03,481] INFO [KafkaServer id=0] started (kafka.server.KafkaServer)

四，创建一个topic

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

此topic只有一个分区，一个副本。
查看topic状态

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
Topic:test      PartitionCount:1        ReplicationFactor:1     Configs:
        Topic: test     Partition: 0    Leader: 0       Replicas: 0     Isr: 0

五，发送消息

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 
>Hello,Kafka
>This is my first Kafka message.
>Hello,Kakfa
>This is my second Kafka message.
>

六，消费消息

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
Hello,Kafka
This is my first Kafka message.

Hello,Kakfa
This is my second Kafka message.