zoukankan      html  css  js  c++  java
  • 基于Kafka的生产者消费者消息处理本地调试


    (尊重劳动成果,转载请注明出处:http://blog.csdn.net/qq_25827845/article/details/68174111冷血之心的博客)


    Kafka下载地址:http://download.csdn.net/download/qq_25827845/9798176

    安装解压就可以

    配置改动zookeeper.properties 与 server.properties改动为本地路径,如图所看到的:

    将config文件夹中的zookeeper.properties 与 server.properties复制到bin/windows下。



    windows的服务脚本在binwindows

     

    (1)启动服务:启动zookeeper:  

      zookeeper-server-start.bat zookeeper.properties      

    cd到binwindows文件夹, 并把zookeeper.properties  复制到这里或者在命令中带上绝对路径


    (2)启动kafka:  

    kafka-server-start.bat server.properties


    (3)关闭服务:在启动服务的cmd窗体, 按ctrl+c另开窗体, 

    运行脚本kafka-server-stop.bat zookeeper-server-stop.bat

    (4)消费測试:建立topic:  

    kafka-topics.bat --create --zookeeper localhost:2181--replication-factor 1 --partitions 1 --topic test_ywq

     

    (5)建立一个Producer, 打开一个cmd窗体,运行: 

    kafka-console-producer.bat --broker-list localhost:9092 --topic test_ywq


    (6)建立一个Consumer, 打开一个cmd窗体,运行:

    kafka-console-consumer.bat --zookeeper localhost:2181 --topic test_ywq


    (7)生产和消费測试:

    当在生产者的消息为hello?时。能够看到。在消费者里边能够消费到hello?




    心得总结:
    1. produce启动的时候參数使用的是kafka的port

    consumer启动的时候使用的是zookeeper的port;
    2.必须先创建topic才干使用。
    3.topic本质是以文件的形式储存在zookeeper上的。



    假设对你有帮助。记得点赞哦~欢迎大家关注我的博客,能够进群366533258一起交流学习哦~






  • 相关阅读:
    自动跳转至首页(Java Script)
    简单的轮播图(Java Script)
    蓝桥杯 2016年 第七届 四平方和(JAVA)
    蓝桥杯 2016年 第七届 剪邮票(JAVA)
    蓝桥杯 2015年 第六届 生命之树(JAVA)
    蓝桥杯 2015年 第六届 垒骰子(JAVA)
    numpy笔记
    opencv安装和运行
    vs code环境配置注意点
    numpy中matrix使用方法
  • 原文地址:https://www.cnblogs.com/slgkaifa/p/7400090.html
Copyright © 2011-2022 走看看