下载相应版本的Kafka二进制包文件。
解压安装：
1
2
| $ tar -xzf kafka_2.13-3.9.0.tgz
$ cd kafka_2.13-3.9.0
|
启动ZooKeeper服务：
1
| $ bin/zookeeper-server-start.sh config/zookeeper.properties
|
启动Kafka服务：
1
| $ bin/kafka-server-start.sh config/server.properties
|
创建Topic：
1
2
| # topic：quickstart-events
$ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
|
查看Topic详情：
1
2
| # topic：quickstart-events
$ bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
|
往Topic投递消息：
1
2
3
| # topic：quickstart-events
$ bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
# 控制台输入消息
|
从Topic消费消息：
1
2
| # topic：quickstart-events
$ bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
|
查看消费者组列表：
1
| $ bin/kafka-consumer-groups.sh --list --bootstrap-server localhost:9092
|
【参考】
Apache Kafka Quickstart