精华内容
下载资源
问答
  • kafka集群启动脚本
    2022-06-28 10:55:41

     Kafka集群启动停止脚本

    1)在/home/atguigu/bin目录下创建脚本kf.sh

    [atguigu@hadoop102 bin]$ vim kf.sh

    在脚本中填写如下内容

    #! /bin/bash
    
    case $1 in
    "start"){
            for i in hadoop102 hadoop103 hadoop104
            do
                    echo " --------启动 $i Kafka-------"
                    # 用于KafkaManager监控
                    ssh $i "export JMX_PORT=9988 && /opt/module/kafka/bin/kafka-server-start.sh -daemon /opt/module/kafka/config/server.properties "
            done
    };;
    "stop"){
            for i in hadoop102 hadoop103 hadoop104
            do
                    echo " --------停止 $i Kafka-------"
                    ssh $i "/opt/module/kafka/bin/kafka-server-stop.sh stop"
            done
    };;
    esac

    说明启动Kafka时要先开启JMX端口,是用于后续KafkaManager监控。

    2)增加脚本执行权限

    [atguigu@hadoop102 bin]$ chmod 777 kf.sh

    3)kf集群启动脚本

    [atguigu@hadoop102 module]$ kf.sh start

    4)kf集群停止脚本

    [atguigu@hadoop102 module]$ kf.sh stop

    更多相关内容
  • kafka集群启动脚本

    2020-09-11 09:11:49
    集群启动脚本1.三台主机之间,需要先免密。2.x x1 x2 修改为相应的主机名3. source /etc/profile; (重要)Java环境所在地方4. 为了命令能够找到我们创建的脚本;可创建到以下任一bin目录; 以/usr/bin 为例以kafka...

    1.三台主机之间,需要先免密。

    2.x x1 x2 修改为相应的主机名

    3. source /etc/profile; (重要)Java环境所在地方

    4. 为了命令能够找到我们创建的脚本;可创建到以下任一bin目录; 以/usr/bin 为例

    echo $PATH
    

    环境变量
    cd /usr/bin/
    vi kk.sh

    以kafka集群启动为例:
    #!/bin/bash
    
    case $1 in
    "start"){
    	for i in x x1 x2
    		do
    			echo --------$i 启动kafka---------
    			ssh $i "source /etc/profile;/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties"
    		done
    };;
    "stop"){
    	for i in x x1 x2
    		do
    			echo --------$i 停止kafka---------
    			ssh $i "source /etc/profile;/opt/kafka/bin/kafka-server-stop.sh stop"
    		done
    };;
    esac
    

    :wq 保存退出

    5.给脚本赋予权限

    chmod 777 kk.sh
    

    kafka 的bin目录下 kafka-server-stop.sh
    有些问题,需要先修改一下官方提供的stop脚本,集群中的每一台机器都要改(注意 kafka 里面的k是小写)

    PIDS=$(ps ax |grep -i 'kafka\.Kafka' | grep java | grep -v grep | awk '{print $1}')

    改为
    PIDS=$(ps ax | grep -i 'kafka' | grep java | grep -v grep | awk '{print $1}')

    注:kafka启动前需要先启动zookeeper。

    6.启动和停止

    启动:kk.sh start
    停止:kk.sh stop

    启动kafka
    jps查看进程
    jps

    停止

    stop

    启动报错解决方法:

    报错的话

    sed -i 's/\r$//' xxx.sh
    

    其他软件集群启动,参考这个

    搞定!

    展开全文
  • kafka 集群启动脚本

    2020-08-01 13:38:18
    #!/bin/bash case $1 in "start"){ for i in xmaster xslave1 xslave2 do echo "------------$i kafka .../home/software/kafka_2.12-2.5.0/bin/kafka-server-start.sh -daemon /home/software/kafka_2.12-2.5.0
    #!/bin/bash
    
    case $1 in
    "start"){
    
    for i in xmaster xslave1 xslave2
    
    do 
        echo "------------$i kafka start----------------"
        ssh $i "source /etc/profile;/home/software/kafka_2.12-2.5.0/bin/kafka-server-start.sh -daemon /home/software/kafka_2.12-2.5.0/config/server.properties"
       
    done
    
    };;
    
    "stop"){
    
    for i in xmaster xslave1 xslave2
    
    do 
       echo "------------$i kafka end---------------"
       ssh $i "source /etc/profile;/home/software/kafka_2.12-2.5.0/bin/kafka-server-stop.sh stop"
    
    done
    };;
    esac
    
    展开全文
  • Kafka 集群启动脚本

    2020-06-04 14:18:25
    1、Kafka 集群群起脚本 (绝对路径) #!/bin/env bash case $1 in "start"){ for i in hadoop102 hadoop103 hadoop104 do ssh $i "source /etc/profile&&/opt/module/kafka/bin/kafka-server-start.sh ...

    1、Kafka 集群群起脚本 (绝对路径)

    #!/bin/env bash
    case $1 in
    "start"){
    	for i in hadoop102 hadoop103 hadoop104
    	do
    		     ssh $i "source /etc/profile&&/opt/module/kafka/bin/kafka-server-start.sh -daemon /opt/module/kafka/config/server.properties"
    		     echo $?
             if [[ $? -eq 0 ]]; then
                     echo "INFO:=======  ${i} 启动成功   =========="
             fi
    	done
    };;
    
    "stop"){
    	for i in hadoop102 hadoop103 hadoop104
    	do
    		      ssh $i "source /etc/profile&&/opt/module/kafka/bin/kafka-server-start.sh -daemon /opt/module/kafka/bin/kafka-server-stop.sh"
    		      echo $?
              if [[ $? -eq 0 ]]; then
                     echo "INFO:=======  ${i} 关闭成功   =========="
              fi
    	done
    };;
    esac
    
    展开全文
  • 启动脚本 在zookeeper集群和kafka集群中间的停顿时间酌情设置 start-kafka-cluster.sh #!/bin/bash brokers="192.168.50.15 192.168.50.16 192.168.50.17" KAFKA_HOME="/usr/local/kafka_2.12-2.8.0" KAFKA_NAME=...
  • 之前介绍过Kafka集群环境的搭建,但是细心的朋友们都发现,Kafka与ZooKeeper一样,都需要在每台节点上执行对应的开启/关闭脚本,十分的不方便。现在我们学习只用到了3台节点,如果以后到了企业,节点多了我们肯定就...
  • kafka一键启动脚本kafkaStart-all.sh #!/bin/bash BROKERS="hadoop01 hadoop02 hadoop03" KAFKA_HOME="/export/servers/kafka_2.11-1.0.0" for broker in $BROKERS do echo "INFO:starting kafka server on $....
  • 上传kafka_2.11-0.11.0.3.tgz 包到三个不同节点上,解压。 配置…/ kafka_2.11-0.11.0.3/config/server....最好使用自己写的脚本启动,将启动命令写入到一个文件: nohup bin/kafka-server-start.sh config/server.p.
  • Kafka 2.1 安装部署 2.1.1 集群规划 hadoop102 hadoop103 hadoop104 zk zk zk kafka kafka kafka 2.1.2 jar...
  • 简介:本篇博客是kafka集群安装部署的详细操作步骤,主要包括了修改相关配置文件、配置环境变量、启动集群、编写启动和停止脚本
  • 脚本一键启动zk,kafka集群

    千次阅读 2022-02-28 22:49:18
    一 zk的一键启动脚本 1.1 脚本内容 #!/bin/bash case $1 in "start"){ for i in 192.168.152.136 192.168.152.138 192.168.152.140 do echo ------------- zookeeper $i 启动 ------------ ssh $i "/root/...
  • #! /bin/bash function kafka_start(){ for host in pc001 pc002 pc003 ... echo "============启动kafka服务 $host==============" ssh $host "kafka-server-start.sh -daemon $KAFKA_HOME/co...
  • 启动 第一步:在/usr/local/bin目录下创建文件xstart-kafka.sh,编辑内容: #!/bin/sh for host in hcmaster hcslave1 hcslave2 do ssh hc@$host "source /etc/profile;nohup kafka-server-start.sh /usr/local/...
  • kakfa启动检查脚本
  • kafka集群脚本启动

    2020-07-26 22:32:38
    echo " --------启动 $i Kafka-------" # 用于KafkaManager监控 ssh $i “export JMX_PORT=9988 && /opt/software/kafka_2.11-0.11.0.0/bin/kafka-server-start.sh -daemon /opt/software/kafka_2.11-0.11....
  • 使用脚本启动kafka无效 脚本如下 for i in hadoop102 hadoop103 hadoop104 do echo "========== $i ==========" ssh $i '/opt/module/kafka/bin/kafka-server-start.sh -daemon /opt/module/kafka/config/server....
  • shell脚本启动kafka集群

    2021-05-13 01:37:51
    前提:kafka集群之间已配置ssh免密登录,kafka集群配置路径一致要实现kafka群起脚本思路:通过ssh登录后,循环启动每台机器的kafka和zookeeperkafka和zookeeper单机启动脚本:remote_server.sh#!/bin/bash#zookeeper...
  • step1:如何启动Kafka集群? step2:如何关闭Kafka集群? step3:如何封装启动及关闭脚本? 实施: 启动Zookeeper /export/server/zookeeper-3.4.6/bin/start-zk-all.sh 启动Kafka bin/kafka-server-start.sh ...
  • kafka集群设置shell脚本一键启动和关闭

    千次阅读 多人点赞 2019-01-15 21:32:43
    前言:最近在做Spark, 做到安装kafka, 安装完想配置一键启动和关闭, 编写启动脚本执行没问题, 关闭的时候遇到了一些问题 ,上网查资料也只能解决一半, 有些博客写的关闭脚本拿过来用执行不能成功,让同事看...

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 15,160
精华内容 6,064
关键字:

kafka集群启动脚本