kafka 以windows服务的方式在windows下安装并自启动

准备工作:

  下载kafka

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

    解压kafka至D:\bigdata\kafka_2.10-0.10.0.0

  
  下载instsrv.exe /srvany.exe

    将instsrv.exe /srvany.exe 拷贝至 D:\bigdata\kafka_2.10-0.10.0.0\bin\windows

1.注册服务

  以管理员身份打开cmd

  cd D:\bigdata\kafka_2.10-0.10.0.0\bin\windows

  instsrv KafkaService D:\bigdata\kafka_2.10-0.10.0.0\bin\windows\srvany.exe

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

2.编辑注册表

  cmd ==> regedit

  定位到以下路径:HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\KafkaService

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

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

    a.名称 Application 值为你要作为服务运行的BAT文件地址:D:\bigdata\kafka_2.10-0.10.0.0\bin\windows\kafka-server-start.bat

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

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

3.启动服务即可。

4.测试kafka

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

  1).生成 Kafka 的 Topic

    打开一个命令行窗口,进入到目录 D:\bigdata\kafka_2.10-0.10.0.0\bin\windows

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

  2).生成生产者

    打开一个命令行窗口,进入到目录 D:\bigdata\kafka_2.10-0.10.0.0\bin\windows

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

  3).生成消费者

    打开一个命令行窗口,进入到目录 D:\bigdata\kafka_2.10-0.10.0.0\bin\windows

    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

上一篇:设计模式初探3——装饰者模式(Decorator Pattern)


下一篇:【原】继承AbstractRoutingDataSource再通过AOP实现动态数据源切换