Kafka 快速入门

快速入门

kafka 下载地址：

http://kafka.apache.org/downloads

解压

# tar -zxvf kafka_2.11-2.1.0.tgz

启动服务

启动 zookeeper

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

启动 Kafka

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

创建 topic

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

发送信息

./kafka-console-producer.sh --broker-list localhost:9092 --topic test

消费信息

./kafka-console-consumer.sh  --bootstrap-server localhost:9092 --topic test --from-beginning

设计一个消息引擎系统时需要考虑的两个重要因素：

消息设计：kafka 的消息使用二进制保存的。

传输协议设计

读到!