Kafka安装使用
2016-09-21 15:10
288 查看
1.安装Java8
2.安装Scala2.11.6
3.下载安装Kafka,解压
启动Zookeeper: bin/zookeeper-server-start.sh config/zookeeper.properties &
启动Kafka: bin/kafka-server-start.sh config/server.properties
我的单机版HBase已经启动Zookeeper了,所以省略第一步。
4.创建Topic。
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
除了可以收到创建topic,还可以配置broker让他自动创建topic。
5.查看topic。
bin/kafka-topics.sh --list --zookeeper localhost:2181
6.发送消息:
运行生产端:bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
就可以输入数据,回车发送
7.接受消息:
运行消费端: bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
单机版安装完成。
2.安装Scala2.11.6
3.下载安装Kafka,解压
启动Zookeeper: bin/zookeeper-server-start.sh config/zookeeper.properties &
启动Kafka: bin/kafka-server-start.sh config/server.properties
我的单机版HBase已经启动Zookeeper了,所以省略第一步。
4.创建Topic。
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
除了可以收到创建topic,还可以配置broker让他自动创建topic。
5.查看topic。
bin/kafka-topics.sh --list --zookeeper localhost:2181
6.发送消息:
运行生产端:bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
就可以输入数据,回车发送
7.接受消息:
运行消费端: bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
你在一个终端中运行consumer命令行,另一个终端中运行producer命令行,就可以在一个终端输入消息,另一个终端读取消息。
单机版安装完成。
相关文章推荐
- KAFKA安装和使用
- KafkaOffsetMonitor的安装和使用
- KafkaOffsetMonitor监控工具的安装与使用
- .net windows Kafka 安装与使用入门(入门笔记)
- .net windows Kafka 安装与使用入门(入门笔记)
- kafka第三篇--安装使用
- kafka-manager的安装与使用
- Linux(CentOS)中常用软件安装,使用及异常——Zookeeper, Kafka
- Kafka安装与使用
- kafka的安装和使用
- kafka安装与使用
- Kafka学习之二 Kafka基本安装使用方法
- kafka安装及Kafka-PHP扩展的使用
- Linux(CentOS)中常用软件安装,使用及异常——Zookeeper, Kafka
- Kafka集群的安装和使用
- kafka安装及使用
- kafka-0.9.0.0安装和使用
- 大数据实验室(大数据基础培训)——Kafka的安装、配置及基础使用
- kafka 安装,使用教程
- java系列之zokeeper与kafka安装使用