zoukankan      html  css  js  c++  java
  • kafka学习笔记

    1、mac安装kafka:brew install kafka

    2、启动zookeeper:zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties

    3、启动kafka:kafka-server-start /usr/local/etc/kafka/server.properties  (kafka-server-start需要设置环境变量才能直接使用,如果报错,先执行kafka-server-stop /usr/local/etc/kafka/server.properties即可)

    4、创建topic:kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic kafka-topic

    5、查看topic列表:kafka-topics --list --zookeeper localhost:2181

    6、生产者命令使用:kafka-console-producer --broker-list localhost:9092 --topic kafka-topic

    7、消费者命令使用:kafka-console-consumer --bootstrap-server localhost:9092 --topic kafka-topic --from-beginning(执行成功后,生产者产生的消息都能在消费者这里出现了)

  • 相关阅读:
    哈希值
    webpack配置(二)
    点击input选中文本
    height:calc(100%
    -webkit-overflow-scrolling
    字符串转数组
    gulp报错160
    webpack配置(一)
    移动端ios中click点击失效
    Spring定时器Quartz的用法
  • 原文地址:https://www.cnblogs.com/zhengchuzhou/p/10950279.html
Copyright © 2011-2022 走看看