kafka-2安装实战篇-创新互联
了解好kafka的基础概念之后,可以开始动手,
成都创新互联从2013年成立,是专业互联网技术服务公司,拥有项目网站制作、做网站网站策划,项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命,1280元海丰做网站,已为上家服务,为海丰各地企业和个人服务,联系电话:13518219792环境:centos7,
官方教程
http://kafka.apache.org/quickstart#quickstart_download
安装java环境,安装jdk(推荐,也省事)
Centos :
yum -y update
yum -y install java
Ubuntu :
sudo apt-get update
sudo apt-get install java
或者也可以通过源码手动安装(如果上面的执行了,这一步到重启环境变量,可以直接跳过了)
http://download.oracle.com/otn-pub/java/jdk/8u131-b11/d54c1d3a095b4ff2b6607d096fa80163/jdk-8u131-linux-x64.tar.gz
tar zxvf jdk-8u65-linux-x64.tar.gz
mv jdk1.8.0_65 java
mv java /java
#设置环境变量,生效
vi .bash_profile
JAVA_HOME=/java
PATH=$PATH:$JAVA_HOME/bin
export JAVA_HOME PATH
#重新启动环境变量,使配置生效
source .bash_profile
下载kafka
https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.2.0/kafka_2.11-0.10.2.0.tgz
> tar -xzf kafka_2.11-0.10.2.0.tgz
> cd kafka_2.11-0.10.2.0
启动zookeeper服务
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
#可以通过ps aux | grep zookeeper
查看起来没有
#编辑kafka配置变量,几个重要的设置
vim config/server.properties num.partitions = 10 #设置partitions数量,在客户端消费时指定多少个线程并发 listeners=PLAINTEXT://192.168.1.200:9092 #设置本机的监听ip及端口,如果为127.0.0.1那从其他机器上将连接不了,需要把192.168.1.200(我的ip)设置成你自己本机的真实ip #设置日志的保存时间,是按byt保存还是按照时间,超过的会自动删除 log.retention.bytes=1073741824 log.retention.hours=168 zookeeper.connect=localhost:2181#本地监听的zookeeper端口,默认即可
启动kafka
bin/kafka-server-start.sh config/server.properties
vim /etc/iptables.startup
#增加
-A KAFKA -p tcp -m tcp --dport 10050 -j ACCEPT
#重启,生效
iptables-restore < /etc/iptables.startup
#查看list
iptables -L
#设置完成后在本地telnet下本机的10050通么,通的话再从其他机器telnet测试下
#如果需要重启kafka或者zookeeper,执行下面kill命令,再重新执行上面启动命令就可以了
ps -ef | grep kafka |awk '{print $2}'|xargs kill -9
另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。
当前文章:kafka-2安装实战篇-创新互联
转载来源:http://scyanting.com/article/hcgde.html