kafka集群安装部署
2016-12-26 11:02
357 查看
kafka集群安装
使用的版本系统:centos6.5 centos6.7
jdk:1.7.0_79
zookeeper:3.4.9
kafka:2.10-0.10.1.0
一.环境准备[只列,不具体写]
1.安装jdk2.更改机器名
3.添加所有机器的host
二.安装步骤
2.1安装zookeeper
下载zookeeper安装包 下载地址将安装包上传到一台电脑node1上,我放到了
/opt/kafka/下
解压
cd /opt/kafka/ tar -zxvf zookeeper-3.4.9.tar.gz
修改配置文件
vi /opt/kafka/zookeeper-3.4.9/conf/zoo.cfg
内容为:
tickTime=2000 dataDir=/opt/kafka/zookeeper-3.4.9/data dataLogDir=/opt/kafka/zookeeper-3.4.9/logs clientPort=2181 initLimit=5 syncLimit=2 server.1=node1:2888:3888 server.2=node2:2888:3888 server.3=node3:2888:3888
创建用到的文件夹
mkdir /opt/kafka/zookeeper-3.4.9/data mkdir /opt/kafka/zookeeper-3.4.9/logs
生成myid文件
echo "1" > /opt/kafka/zookeeper-3.4.9/data/myid
将zookeeper文件夹发到其他机器上
scp -r /opt/kafka/zookeeper-3.4.9 root@node2:/opt/kafka/zookeeper-3.4.9 scp -r /opt/kafka/zookeeper-3.4.9 root@node3:/opt/kafka/zookeeper-3.4.9
分别在其他机器上运行
echo "2" > /opt/kafka/zookeeper-3.4.9/data/myid
echo "3" > /opt/kafka/zookeeper-3.4.9/data/myid
要保证每一台的myid文件里的内容都不一样
在每一台机子上启动zk
/opt/kafka/zookeeper-3.4.9/bin/zkServer.sh start
检查zk状况
/opt/kafka/zookeeper-3.4.9/bin/zkServer.sh status
如图类似的信息则正常开启
2.2安装kafka
下载kafka安装包 下载地址上传安装包到一台机子上
解压
tar -zxvf /opt/kafka/kafka_2.10-0.10.1.0.tgz
建立kafka日志存放文件夹
mkdir /opt/kafka/kafka_2.10-0.10.1.0/kafkalogs
修改配置文件
vi /opt/kafka/kafka_2.10-0.10.1.0/config/server.properties
修改内容为:
# log.dirs=/tmp/kafka-logs log.dirs=/opt/kafka/kafka_2.10-0.10.1.0/kafkalogs # zookeeper.connect=localhost:2181 zookeeper.connect=node1:2181,node4:2181,node8:2181
将kafka文件夹发到其他机子上
scp -r /opt/kafka/kafka_2.10-0.10.1.0 root@node2:/opt/kafka/kafka_2.10-0.10.1.0 scp -r /opt/kafka/kafka_2.10-0.10.1.0 root@node3:/opt/kafka/kafka_2.10-0.10.1.0
在其他机器上更改broker.id
vi /opt/kafka/kafka_2.10-0.10.1.0/config/server.properties
把broker.id改成其他数字,每台机子不能一样
启动kafka
cd /opt/kafka/kafka_2.10-0.10.1.0 bin/kafka-server-start.sh config/server.properties &
如图类似的信息则正常开启
三.遇到的问题及解决
问题:
A broker is already registered on the path /brokers/ids/0.解决
配置文件里存在broker.id重复,检查一下每一台的broker.id是否与其他机器的broker.id不一样问题
Exception in thread "main" java.lang.UnsupportedClassVersionError: kafka/Kafka : Unsupported major.minor version 51.0解决
jdk版本不对,我用的kafka版本:2.10-0.10.1.0 对应jdk版本:1.7 不能用1.6问题
ERROR Processor got uncaught exception. (kafka.network.Processor)java.nio.BufferUnderflowException
解决
客户端的jar包和集群的版本号在小版本不一致,注意客户端的jar包不只要大版本一致,还要小版本完全一致,不一致的时候报的错不只这个.相关文章推荐
- 生产环境实战spark (11)分布式集群 5台设备 Zookeeper集群、Kafka集群安装部署
- zookeeper+kafka集群安装部署
- Kafka集群安装部署、Kafka生产者、Kafka消费者
- Kafka详细教程:下载、安装、配置与集群部署
- kafka集群管理工具kafka-manager部署安装
- 安装部署(六) Kafka集群安装部署以及Producer和Consumer的JAVA代码测试
- kafka 集群的部署安装
- centos7下kafka集群安装部署
- Kafka 安装部署及使用(单节点/集群)
- docker kafka集群安装部署
- kafka集群安装部署及常用命令
- kafka集群管理工具kafka-manager部署安装
- kafka集群安装部署
- Linux下部署Kafka分布式集群,安装与测试
- apusic培训整理(服务器安装、应用部署、建立集群)
- Ganglia监控Hadoop集群的安装部署
- LinuxHA集群部署安装说明
- Cloudera Hadoop集群安装部署,cdh3u6,Ubuntu12.04
- RHEL5.7上MySQL-Cluster-7.2.13双机集群安装部署手册
- Hadoop+hive 集群安装部署 (三)