kafka 快速入门使用

Kafka的核心功能

高性能的消息发送和高性能的消息消费的消息引擎系统

使用简介

下载->启动服务器->创建topic->发送，消费消息
官网下载kafka二进制安装包
解压到相应的文件夹下，然后执行：
1. 启动为kafka提供协调服务的工具zookeeper，在解压后的目录下执行bin/zookeeper-server-start.sh config/zookeeper.properties
2. 启动kafka服务器
在解压后的目录下执行bin/kafka-server-start.sh config/server.properties
3. 创建topic
打开新的中端bin/kafka-topics.sh --create --zookeeper localhost:2181 --topic test --partitions 1 --replication-factor 1
创建成功会显示Created topic test.
查看建立的终端：
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

4. 发送和接收消息
打开两个新的终端，分别用来发送和接收消息：
发送消息的终端，执行bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test输入要发送的字符，回车后成功发送
接收消息的终端，执行bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning，控制台会接收到发送的消息。
可以在发送终端，不断地发送信息，接收消息的终端会不断地接收到新的消息