Kafka单机安装
2015-11-04 00:24
316 查看
前提条件:安装zookeeper,见下文
http://blog.csdn.net/jameshadoop/article/details/49621709
环境:
centos 6.5 x64
kafka_2.9.2-0.8.1.1
2.2启动kafka
通过list命令查看创建的topic:
此时随便输入一条消息并回车
I’m James
I’m James
停止Zookeeper server:
结束
http://blog.csdn.net/jameshadoop/article/details/49621709
环境:
centos 6.5 x64
kafka_2.9.2-0.8.1.1
1.解压
tar -xzf kafka_2.9.2-0.8.1.1.tgz2.启动
2.1要先启动zookeepersh $zookeeper_home/bin/zkServer.sh start
2.2启动kafka
bin/kafka-server-start.sh config/server.properties &
3测试
创建 topic:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
通过list命令查看创建的topic:
bin/kafka-topics.sh --list --zookeeper localhost:2181
生产消息:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
此时随便输入一条消息并回车
I’m James
消费消息:
另启动一个窗口bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
I’m James
4.停止kafka
停止Kafka serverbin/kafka-server-stop.sh
停止Zookeeper server:
sh $zookeeper_home/bin/zkServer.sh stop
结束
相关文章推荐
- Kafka 之 中级
- Shell脚本实现自动安装zookeeper
- 基于Zookeeper的使用详解
- 基于zk的配置管理
- SolrCloud4.9+zookeeper在CentOS上的搭建与安装
- 基于外部ZooKeeper的GlusterFS作为分布式文件系统的完全分布式HBase集群安装指南
- redis集群搭建
- 使用 RMI + ZooKeeper 实现远程调用框架
- 轻量级分布式 RPC 框架
- 整合Kafka到Spark Streaming——代码示例和挑战
- HBase 系统架构
- 使用zookeeper实现分布式共享锁
- 将Zookeeper集成到你的应用中
- 基于zookeeper+leveldb搭建activemq集群
- Kafka深度解析
- Kafka设计解析(三)- Kafka High Availability (下)
- Fourinone四合一分布式计算框架整体介绍
- kafka+storm初探
- storm集群 + kafka单机性能测试