概要
最近打算学习下kafka,虽然网上有很多部署实例,不过自己还是打算配置下,走下流程,心里有个底,那么第一个小目标就是先把kafka跑起来,然后稍微理解一点部署涉及到环境知识。
注意点
笔者用的是阿里云ecs最低配置,系统为Ubuntu 16.04.2,对于非docker安装kafka,总体安装下来,主要头痛的还是1G内存的限制,因为贫穷,所以只能花更多时间去清下一些内存占用
开始装环境
1. java环境安装
ubuntu 最简单安装法:
sudo apt-get update
sudo apt-get install openjdk-8-jdk
2. 下载安装包解压
//这里下的是tgz的
wget "官方下载地址" -O ~/Downloads/kafka.tgz
cd
mkdir kafka
cd kafka
tar -xvzf ~/Downloads/kafka.tgz
3. 贫穷的悲哀,调整kafka启动内存,bin/kafka-server-start.sh
KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
修改为
KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"
4. 调整配置文件修改端口 config/server.properties下
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://外网ip:9092
zookeeper.connect=0.0.0.0:2181
启动kafka
shell:1
bin/zookeeper-server-start.sh config/zookeeper.properties
shell:2
bin/kafka-server-start.sh config/server.properties
如果启动不成功
//看下空闲内存
free -m
//如果不够用的话,查询内存消耗最多的前10个进程
ps auxw|head -1;ps auxw|sort -rn -k4|head -10
//把消耗内存多的非系统进程停掉
简单数据操作,检测安装成功与否
//生产
bin/kafka-console-producer.sh --broker-list 0.0.0.0:9092 --topic ttt1
>1
>哈哈
>3
//消费
bin/kafka-console-consumer.sh --zookeeper 0.0.0.0:2181 --topic ttt1 --from-beginning
1
哈哈
3
kafka-manager配置,这里因为ecs1G内存的贫穷,所以使用sbt编辑源码我是一直没成功,kafka的启动又占了很多内存资源,所以还是在自己的笔记本上直接走docker了,毕竟只是一个可视化工具
docker run -it --rm -p 9000:9000 -e ZK_HOSTS="IP地址:2181" -e APPLICATION_SECRET=letmein sheepkiller/kafka-manager
kafka-manager安装成功截图
网友评论