zoukankan      html  css  js  c++  java
  • kafka 安装

    1. 解压安装文件

      链接:https://pan.baidu.com/s/1qzwYJeiHmb__do3lkkrLnA 

      提取码:1r8a

    2. 进入 config 中修改 server.properties

    3. 修改   

      host.name=hadoop1
      port=9092

      zookeeper.connect=hadoop1:2181

    4. 启动 kafka,  首先需要先启动  zookeeper  然后执行如下命令启动 kafka

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

    5. jps 查看

    6. 验证 kafka 

      1》新建 topic  名字为:recommender1

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

      2》新开窗口,启动一个 console 生产者:

        bin/kafka-console-producer.sh --broker-list hadoop1:9092 --topic recommender1

      3》新开窗口,启动一个 console 消费者:

        bin/kafka-console-consumer.sh --bootstrap-server hadoop1:9092 --topic recommender1

      4》再 2》  中输入字符串,  3》窗口中就可以收到对应的字符串了

        

  • 相关阅读:
    linux 6 安装 Nagios服务
    linux 6 安装 Nginx服务
    Rsync的配置与使用
    linux 6 搭建 msyql 服务
    linux6搭建Apache服务
    Linux 7搭建NFS服务
    Linux 6 忘记root密码重置
    简单makefile
    多线程c++11编程题目
    redis 代码结构与阅读顺序
  • 原文地址:https://www.cnblogs.com/redhat0019/p/11550156.html
Copyright © 2011-2022 走看看