zoukankan      html  css  js  c++  java
  • kafka cmd首个单机例子配置

    下载地址:http://kafka.apache.org/downloads       http://mirror.bit.edu.cn/apache/kafka/2.3.0/kafka_2.12-2.3.0.tgz

    zookeeper.properties修改dataDir

    dataDir=G:zookeeper-3.5.5data
    # the port at which the clients will connect
    clientPort=2181
    # disable the per-ip limit on the number of connections since this is a non-production config
    maxClientCnxns=0

    server.properties修改log.dirs

    ############################# Log Basics #############################
    
    # A comma separated list of directories under which to store log files
    log.dirs=G:kafkalogs

    运行zookeeper命令

    zkserver

    进入cd G:kafkainwindows

    启动服务:

    kafka-server-start.bat ../../config/server.properties

    创建实例

    kafka-topics.bat --create --zookeeper localhost:2181 --repl
    ication-factor 1 --partitions 1 --topic testDemo

    生产者

    kafka-console-producer.bat --broker-list localhost:9092 --t
    opic testDemo

    消费者

    kafka-console-consumer.bat --bootstrap-server localhost:909
    2 --topic testDemo --from-beginning

    在生产者里输入内容,消费者就打印出相应内容

  • 相关阅读:
    UVa中国麻将(Chinese Mahjong,Uva 11210)
    Nginx-upstream模块
    Nginx-配置文件
    Nginx 负载均衡和反向代理实践
    Nginx-1
    linux下发送报警邮件(mailx)
    dns服务器搭建
    linux 时间相关
    Centos7调整swap分区
    rm 删除命令
  • 原文地址:https://www.cnblogs.com/tk55/p/11409038.html
Copyright © 2011-2022 走看看