zoukankan      html  css  js  c++  java
  • Kafka学习入门(windows环境下)

    1.创建一个topic (它有一个分区和副本)

    binwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

    2.查看已有的topic

    binwindowskafka-topics.bat --list --zookeeper localhost:2181

    3.发送消息

    binwindowskafka-console-producer.bat --broker-list localhost:9092 --topic test        //test表示把消息发送到名为test的topic中

    Kafka自带一个命令行客户端,它从文件或标准输入中获取输入,并将其作为message(消息)发送到Kafka集群。默认情况下,每行将作为单独的message发送。

    4.启动一个 consumer 接收消息

     binwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

    5.设置多代理集群

    (1)为每一个代理创建配置文件(复制config/server.properties文件,修改配置中的端口号

    复制出了配置文件:server-1.properties  与 server-2.properties

    修改主要配置项:

    config/server-1.properties:
        broker.id=1
        listeners=PLAINTEXT://:9093
        log.dir=/tmp/kafka-logs-1

    注:broker.id属性是集群中每个节点的名称,这一名称是唯一且永久的。我们必须重写端口和日志目录,因为我们在同一台机器上运行这些,我们不希望所有的代理尝试在同一个端口注册,或者覆盖彼此的数据。

  • 相关阅读:
    Keyboarding题解
    埃及分数 解题报告
    小木棍加强版解题报告
    扩展欧几里得
    luoguP4999 烦人的数学作业
    中国剩余定理
    20201115gryz模拟赛解题报告
    扩展欧几里得算法
    斐蜀定理
    CSP2020-S游记
  • 原文地址:https://www.cnblogs.com/yxcn/p/13344810.html
Copyright © 2011-2022 走看看