Kafka 安装

参考 http://kafka.apache.org/documentation.html#quickstart

下载

wget "http://apache.osuosl.org/kafka/0.10.0.0/kafka_2.11-0.10.0.0.tgz"
tar -zxvf kafka_2.11-0.10.0.0.tgz
sudo mkdir /usr/lib/kafka
sudo mv kafka_2.11-0.10.0.0 /usr/lib/kafka

运行Kafka

启动zookeeper

cd /usr/lib/kafka/kafka_2.11-0.10.0.0
bin/zookeeper-server-start.sh config/zookeeper.properties

启动kafka

cd /usr/lib/kafka/kafka_2.11-0.10.0.0
bin/kafka-server-start.sh config/server.properties

测试

运行producer

cd /usr/lib/kafka/kafka_2.11-0.10.0.0
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
This is a message
This is another message

运行consumer

cd /usr/lib/kafka/kafka_2.11-0.10.0.0
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning