zoukankan      html  css  js  c++  java
  • kafka 以windows服务的方式在windows下安装并自启动

    准备工作:

      下载kafka

        http://apache.fayea.com/kafka/0.10.0.0/kafka_2.10-0.10.0.0.tgz

        解压kafka至D:igdatakafka_2.10-0.10.0.0

      
      下载instsrv.exe /srvany.exe

        将instsrv.exe /srvany.exe 拷贝至 D:igdatakafka_2.10-0.10.0.0inwindows

    1.注册服务

      以管理员身份打开cmd

      cd D:igdatakafka_2.10-0.10.0.0inwindows

      instsrv KafkaService D:igdatakafka_2.10-0.10.0.0inwindowssrvany.exe

      卸载服务:instsrv KafkaService remove 或 sc delete KafkaService

    2.编辑注册表

      cmd ==> regedit

      定位到以下路径:HKEY_LOCAL_MACHINESYSTEMCurrentControlSetServicesKafkaService

      如果该服务名下没有Parameters项目,则对服务名称项目右击新建项,名称为Parameters,

      定位到Parameters项,新建以下几个字符串值:

        a.名称 Application 值为你要作为服务运行的BAT文件地址:D:igdatakafka_2.10-0.10.0.0inwindowskafka-server-start.bat

        b.名称 AppDirectory 值为你要作为服务运行的BAT文件所在文件夹路径:D:igdatakafka_2.10-0.10.0.0inwindows

        c.名称 AppParameters 值为你要作为服务运行的BAT文件启动所需要的参数:D:igdatakafka_2.10-0.10.0.0configserver.properties

    3.启动服务即可。

    4.测试kafka

      参考地址:http://www.open-open.com/lib/view/open1453179304245.html

      1).生成 Kafka 的 Topic

        打开一个命令行窗口,进入到目录 D:igdatakafka_2.10-0.10.0.0inwindows

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

      2).生成生产者

        打开一个命令行窗口,进入到目录 D:igdatakafka_2.10-0.10.0.0inwindows

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

      3).生成消费者

        打开一个命令行窗口,进入到目录 D:igdatakafka_2.10-0.10.0.0inwindows

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

      在生产者命令行窗口内随便输入一段字符,然后回车,你应该能看到同样的消息出现在消费者的命令行窗口内

      如果在消费者端能看到你推送的消息,那么你已经成功的安装了Kafka

    5.kafka监控

      1.Apache Kafka监控之KafkaOffsetMonitor

      2.Apache Kafka监控之Kafka Web Console

    参考网址:

    http://damacheng009.iteye.com/blog/2087916?utm_source=tuicool&utm_medium=referral

    一些有用的命令

    1. 列举 Topic: kafka-topics.bat --list --zookeeper localhost:2181

    2. 描述 Topic: kafka-topics.bat --describe --zookeeper localhost:2181 --topic [Topic Name]

    3. 从头读消息: kafka-console-consumer.bat --zookeeper localhost:2181 --topic [Topic Name] --from-beginning

    4. 删除 Topic: kafka-run-class.bat kafka.admin.TopicCommand --delete --topic [topic_to_delete] --zookeeper localhost:2181

    作者:mrluo735

    -------------------------------------------

    个性签名:恬淡的生活态度,适当的坚持付出,散发出你闪耀的人生哲学!

    如果觉得这篇文章对你有小小的帮助的话,记得在右下角点个 [推荐]哦,博主在此感谢!

    万水千山总是情,打赏一分行不行,所以如果你心情还比较高兴,也是可以扫码打赏博主,哈哈哈(っ•̀ω•́)っ✎⁾⁾!

  • 相关阅读:
    R语言中的字符串处理函数
    flask模板应用-javaScript和CSS中jinja2 --
    flask模板应用-自定义错误页面 --
    flask模板应用-消息闪现(flash()) --
    flask模板应用-加载静态文件:添加Favicon,使用CSS框架,使用宏加载静态资源 --
    flask模板应用-空白控制 --
    flask模板结构组织(局部模板、宏、模板继承)--
    flask模板的基本用法(定界符、模板语法、渲染模板),模板辅助工具(上下文、全局对象、过滤器、测试器、模板环境对象) --
    CSRF(跨站请求伪造)攻击 --
    XSS攻击原理、示例和防范措施 --
  • 原文地址:https://www.cnblogs.com/mrluo735/p/5844470.html
Copyright © 2011-2022 走看看