先从我的集束部署步骤开始
1.在线下载安装包
wget https://archive.apache.org/dist/kafka/2.1.0/kafka_2.12-2.1.0.tgz
解压到opt目录下
tar -zxf kafka_2.12-2.1.0.tgz -C /opt
更改日志的位置, 在 Conf. property 中创建相关文件夹 。
log.dirs=/opt/data
# 因为动物园管理员是一棵目录树, 必须在最后建造一个卡夫卡目录,
zookeeper.connect= 192.168.6.100:2181,192.168.6.101:2181,192.168.6.102:2181/kafka
配置环境变量
vim /etc/profile
export KAFKA_HOME=/opt/kafka
export PATH=$PATH:$KAFKA_HOME/bin
从新加载环境变量
source /etc/profile
所以我只克隆了两台虚拟机器作为集群, 并在 conf. 下更改了服务器。 属性中的经纪人. id, 因为已配置了固定的 IP 地址, 并更改了固定的 IP 地址 。
vim /etc/sysconfig/network-scripts/ifcfg-ens33
在你开始卡夫卡之前,你必须先开始动物园keper。在你关掉动物园管理员之前,你必须先关掉卡夫卡。
当动物园管理员开始的时候,请使用命令启动 kafka 。
bin/kafka-server-start.sh -daemon config/server.properties
我在此输入命令时, 命令行没有反应 。
键入 jps 命令以观看程序启动, Kafka 被发现不启动( 安装 jps 命令)
yum install java-1.8.0-openjdk-devel.x86_64
此时此刻,我们可以检查日志
tail -n50 -f /opt/kafka_2.12-2.1.1/nohup.out
日志提示
kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
at kafka.zookeeper.ZooKeeperClient.$anonfun$waitUntilConnected$3(ZooKeeperClient.scala:268)
线索流出的时间, 在线搜索没有结果, 然后我突然想到,如果 动物猎手没有开始。
检查动物园管理员状况,然后输入动物园管理员文件。
bin/zkServer.sh status
动物园管理员不适合我 检查动物园管理员的日志
./zkServer.sh start-foreground
我无法找到一个绑定的地图界面, 但是在它被修改之前, 第一件想到的事情是 港口是否被占用了。
grep Netstatat-anp 端口号
Kill-9 港口号(关闭港口程序)
由于港口号没有占用,我假定主机地图没有设置,导致地图失败。
IP 地址和主机名存储在 / etc/ hosts 文件中,发现 ip 的地图不同于固定 ip, 需要修改 / hosts 地图 。
当我使用重新加载启动命令时, 动物园管理员真的开始了它。 输入 jps 并开始 Kafka 发现它已经开始了 。
关闭kafka命令
bin/kafka-server-stop.sh