kafka单机模式部署安装,zookeeper启动

    技术2022-07-16  76

    kafka单机模式部署安装,zookeeper启动

    在root的用户下

    1):前提 安装JDK环境,设置JAVA环境变量

    2):下载kafka

    3):下载zookeeper

    4):然后去解压zookeeper包,首先找到conf的文件夹,然后备份一份zoo_sample.cfg文件 ,备份名为zoo.cfg

    命令:cp zoo_sample.cfg zoo.cfg

    5):打开zoo.cfg的文件

    命 令 :vim zoo.cfg

    dataDir=/tmp/zookeeper (虽然给出这个路径给你,但是系统并没有,要你自己创建的,你可以不按这个路径) dataLogDir=/tmp/zookeeperlog (这是我另外夹的用来存放日志文件)

    6):启动 zookeeper 命令

    root@caleb-vm:/usr/local/zookeeper# ./bin/zkServer.sh start

    ​ 查看zookeeper启动状态

    root@caleb-vm:/usr/local/zookeeper# ./bin/zkServer.sh status

    7)解压kafka的包,我把kafka_2.12-2.5.0.tgz文件夹名称改为了kafka,到config路径下找到 server.properties

    找到log.dirs=/tmp/kafka-logs (跟刚刚zookeper一样创建)

    ​ listeners(*所在机器ip地址*)

    8):启动kafka

    命令:nohup bin/kafka-server-start.sh config/server.properties &

    运行之后不管成功否它都会在你的kafka包下生成一个 nohup.out的文件

    9): 查看是否成功了

    新建一个topic命令:

    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

    查看 topic是否成功命令:

    bin/kafka-topics.sh --list --zookeeper localhost:2181

    10):把kafka的生产者启动来 命令 :

    bin/kafka-console-producer.sh --broker-list 192.168.183.128:9092 --topic test

    11):另开一个终端(创建新的),把消费者启动起来命令:

    bin/kafka-console-consumer.sh --bootstrap-server 192.168.183.128:9092 --topic test --from-beginning

    12):在生产者终端输入数据,消费者马上就会消费显示出来

    Processed: 0.021, SQL: 10