zoukankan      html  css  js  c++  java
  • kafka完全分布式搭建(2.12版)

    1、下载解压

      tar -xvf kafka_2.12-1.0.0.tgz

    2、进入config目录下,修改server.propeties文件

      broker.id=0 #当前server编号

      port=9092 #使用的端口

      log.dirs=/tmp/kafka-logs-1 #日志存储目录

      zookeeper.connect=localhost:2181

    3、启动zookeeper

      zkServer.sh start

    4、启动kafka

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

    **************************************************

    使用kafka

    1)、创建topic:

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

    2)、查看topic: 

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

    3)、生产者

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

    4)、消费者

      bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

    5)、删除topic

      ./bin/kafka-topics --delete --zookeeper 【zookeeper server:port】 --topic 【topic name】

      [server.properties需要 设置delete.topic.enable=true]

    **************************************************

  • 相关阅读:
    构建之法阅读笔记01
    最长英语单词链
    第十五周学习总结
    寻找“水王”
    Happy Necklace HDU
    Bi-shoe and Phi-shoe LightOJ
    The Embarrassed Cryptographer POJ
    Big Number HDU
    矩阵乘法模板C/C++
    Baby Step,Giant Step算法模板
  • 原文地址:https://www.cnblogs.com/runnerjack/p/7846744.html
Copyright © 2011-2022 走看看