一 . kafka 快速安装使用
1.1 下载kafka
tar -xzf kafka_2.11-0.10.2.0.tgz
cd kafka_2.11-0.10.2.0
1.2 开启服务 启动ZooKeeper(如果没有可以启用默认的) 和Kafka
注意:下面启动是非后台启动,如果已启动ZooKeeper不需要第一步
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties
后台启动
nohup bin/kafka-server-start.sh config/server.properties &
或者
bin/kafka-server-start.sh -daemon config/server.properties
1.3 创建一个topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
1.4 创建发送信息控制台(生产者),发送信息(producer)
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
可以在控制台来发送信息
1.5 开启一个消费者(consumer)
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning