zoukankan      html  css  js  c++  java
  • kafka centos安装发送消费消息

    1. 请先下载安装文件,java环境需提前安装,解压到指定目录:
    tar -zxvf kafka_2.11-2.3.1.tgz -C /root/soft/

    从官网下载文件,上传到centos虚拟机指定路径下,当前download文件夹下面

     

     解压到指定目录soft文件夹下面:

    2. 创建zk日志目录。
    mkdir zklogs
    3. 查看是否启动成功,
    ps -ef | grep zookeeper

     4. 启动zookeeper

    nohup bin/zookeeper-server-start.sh ./config/zookeeper.properties &

     5. 修改kafka配置

    vim config/server.properties
    执行命令 vi config/server.properties 修改kafka的配置信息
    修改advertised.host.name和advertised.port信息
    修改日志文件路径:
    修改log.dirs=/root/soft/kafka-logs为log.dirs=/root/soft/kafka/logs 该参数为kafka日志文件存放路径

    advertised.host.name=192.168.132.152
    advertised.port=9092

    log.dirs=/root/soft/kafka/logs

     

     6. 启动kafka

    nohup bin/kafka-server-start.sh ./config/server.properties

     执行命令ps -ef | grep kafka查看kafka是否启动成功

    7. 创建mytest主题
    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytest

     获取所有topic

    bin/kafka-topics.sh --list --zookeeper localhost:2181
    8. 生产测试消息
    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytest

     9. 消费消息

    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mytest --from-beginning

     kafka和java安装文件网盘下载地址:

    链接:https://pan.baidu.com/s/1DhbzsKvqB7Y3S9QJQUUK9A
    提取码:zim2

  • 相关阅读:
    linux shell获取用户输入
    yii2 笔记(1)
    yii2 数据库查询
    Yii2 环境配置生产环境和测试环境
    mysql 中find_in_set()和in()用法比较
    使用js提交form表单的两种方法
    base64编码的原理及实现
    浅析HTTP/2的多路复用
    Nginx 所使用的 epoll 模型是什么?
    git代码统计
  • 原文地址:https://www.cnblogs.com/xiaozw/p/11743841.html
Copyright © 2011-2022 走看看