Kafka从零开始 (Quickstart)
kafka 快速开始
- 第1步:下载代码
官网下载:https://www.apache.org/dyn/closer.cgi?path=/kafka/2.1.0/kafka_2.11-2.1.0.tgz - 第2步:启动服务器
Kafka使用ZooKeeper,因此如果您还没有ZooKeeper服务器,则需要先启动它。您可以使用与kafka一起打包的便捷脚本来获得快速且脏的单节点ZooKeeper实例。
macbook安装 kafka:https://www.jianshu.com/p/1f6387d18989(个人测试学习 严格来说建议安装在linux上)
其中官网有详细下载教程:https://kafka.apache.org/quickstart - 第3步:创建主题
让我们创建一个名为“test”的主题,它只包含一个分区,只有一个副本:
> bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
以上为官网示例代码 本机为 mac 不需要加.sh 后同
- 第4步:发送一些消息
Kafka附带一个命令行客户端,它将从文件或标准输入中获取输入,并将其作为消息发送到Kafka集群。默认情况下,每行将作为单独的消息发送。
运行生产者,然后生产一些消息到kafka中
> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
This is a message
This is another message
tips: ctrl + c 退出生产者客户端
- 第5步:启动消费者
同理kafka也有消费命令行使用者,它会将消息转储到标准输出
> bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
This is a message
This is another message
如果您在不同的终端中运行上述每个命令,那么您现在应该能够在生产者终端中键入消息并看到它们出现在消费者终端中。