kafka 安装部署
2017-09-19 15:20
239 查看
环境:ubuntu 12.04 64位桌面版
解压kafka
进入目录
创建data 目录
配置 config/server.properties 配置文件
zookeeper.connect=chen:2181 , chen是我的机器HOSTNAME,所以这里大家可以自行修改
启动kafka 服务 (这里我没有启动kafka 自带的zookeeper 服务,而是自己使用搭建的zookeeper 服务,事实证明可行)
创建一个topic,名字叫test
查看当前kafka 有哪些 topic
查看一下这个test 的topic
启动一个kafka 生产者
启动kafka 消费者
再一次备注:chen 是我的机器HOSTNAME,大家应该根据自己的环境做相应的调整
删除 topic
如果 delete.topic.enable 参数没有设置为true ,则删除topic 时,不会在zookeeper 上同步删除。
停止kafka 服务的命令
参考博客:
http://www.cnblogs.com/luotianshuai/p/5206662.html
解压kafka
tar -zxvf /mnt/hgfs/mnt/kafka_2.11-0.10.0.0.tgz -C /root/software/
进入目录
cd kafka_2.11-0.10.0.0/
创建data 目录
mkdir /root/software/kafka_2.11-0.10.0.0/data
配置 config/server.properties 配置文件
broker.id=0 #如果是配置kafka 集群环境, 每台机器上的broker 值必须不一样 port=9092 log.dir=/root/software/kafka_2.11-0.10.0.0/data/log zookeeper.connect=chen:2181 delete.topic.enable=true
zookeeper.connect=chen:2181 , chen是我的机器HOSTNAME,所以这里大家可以自行修改
启动kafka 服务 (这里我没有启动kafka 自带的zookeeper 服务,而是自己使用搭建的zookeeper 服务,事实证明可行)
bin/kafka-server-start.sh -daemon config/server.properties
创建一个topic,名字叫test
bin/kafka-topics.sh --create --zookeeper chen:2181 --replication-factor 1 --partitions 1 --topic test
查看当前kafka 有哪些 topic
bin/kafka-topics.sh --list --zookeeper chen:2181
查看一下这个test 的topic
bin/kafka-topics.sh --describe --zookeeper chen:2181 --topic test-replicated-topic
启动一个kafka 生产者
bin/kafka-console-producer.sh --broker-list chen:9092 --topic test
启动kafka 消费者
bin/kafka-console-consumer.sh --zookeeper chen:2181 --topic test --from-beginning
再一次备注:chen 是我的机器HOSTNAME,大家应该根据自己的环境做相应的调整
删除 topic
bin/kafka-topics.sh --delete --zookeeper chen:2181 --topic test
如果 delete.topic.enable 参数没有设置为true ,则删除topic 时,不会在zookeeper 上同步删除。
停止kafka 服务的命令
bin/kafka-server-stop.sh -daemon
参考博客:
http://www.cnblogs.com/luotianshuai/p/5206662.html
相关文章推荐
- Kafka安装及部署
- kafka管理器kafka-manager部署安装
- docker kafka集群安装部署
- filebeat+kafka+ELK5.4安装与部署
- kafka集群安装部署
- 一、kafka原理、部署安装、常用命令
- 安装部署kafka
- kafka集群管理工具kafka-manager部署安装
- kafka系列之安装及初步使用,单节点部署使用(一)
- kafka及zookeeper安装部署
- zookeeper+kafka集群安装部署
- Kafka安装部署
- 生产环境实战spark (11)分布式集群 5台设备 Zookeeper集群、Kafka集群安装部署
- Linux下单机安装部署kafka及代码实现
- Kafka安装部署
- 大数据学习之——kafka安装部署
- Kafka的安装和部署及测试
- 安装部署(六) Kafka集群安装部署以及Producer和Consumer的JAVA代码测试
- 02-10版本kafka安装部署
- Kafka安装部署