zoukankan      html  css  js  c++  java
  • Kafka单机单节点部署

    1、下载地址:
    https://mirrors.bfsu.edu.cn/apache/kafka/2.5.0/kafka_2.13-2.5.0.tgz

    2、下载后,解压:tar -zxvf kafkaxxxxxx.tgz

    3、删除 LICENSE、NOTICE 、site-docs

    4、进入bin目录:cd bin

    5、启动:
    ①.启动zookeeper:
    nohup ./zookeeper-server-start.sh ../config/zookeeper.properties &
    ②.启动Kafka:
    nohup ./kafka-server-start.sh ../config/server-2.properties &


    6、创建topic
    ./kafka-topics.sh --create --zookeeper Icloud_143:2181 --replication-factor 1 --partitions 1 --topic test

    7、查看topic
    ①查看所有topic
    ./kafka-topics.sh --list --zookeeper zhangqi:2181
    ②查看当前创建的topic描述
    ./kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic

    8、启动生产者(控制台)
    ./kafka-console-producer.sh --broker-list zhangqi:9092 --topic test

    9、启动消费者(控制台)
    ./kafka-console-consumer.sh --bootstrap-server zhangqi:9092 --topic test

    10、在生产者控制台输入字符串,可以看到消费者控制台进行消费并打印。

    11、也可以一次性消费之前所有的消息:
    ./kafka-console-consumer.sh --bootstrap-server zhangqi:9092 --topic test --from-beginning

  • 相关阅读:
    php 魔术方法
    有用的函数系统采集(一)
    php后期静态绑定
    php对象引用及序列化
    php文件操作
    复习mysql视图总结
    jQuery调用WebService详解
    这个网站的界面描述甚好,我喜欢
    喜欢和技术有关的一切~
    Introduction
  • 原文地址:https://www.cnblogs.com/malcolmfeng/p/13372047.html
Copyright © 2011-2022 走看看