你的位置:首页 > Java教程

[Java教程]跟我一起学kafka(二)


  kafka安装到linux服务器中的情况较多,但是我们现在在学习当中,所以可以拿windows先试试手。要想学kafk那么必然要做一件事就是安装好kafka,下面我讲详细得windows下安装kafka得步骤告诉大家。

  第一步:先安装jdk,因为kafka依赖于Java环境,所以确保你的系统中装有JDK(安装jdk我就不说了,请自行百度,在此分享一个下载链接:http://pan.baidu.com/s/1i5jgMFF)

  第二步:这里我们要使用完全的zookeeper,而不是用Kafka打包的那个,因为这是一个单节点的Zookeeper实例。也可以运行打包了zookeeper的Kafka,位置在\kafka\bin\windows库中。下载地址:http://pan.baidu.com/s/1c12D7C8.这里面包含zookeeper和kafka得下载链接,请注意哦

  第三步:解压你得zookerper到你指定得目录,我解压到了F盘

其他得不用动,端口号默认为2181就行。

2)。在系统变量中添加ZOOKEEPER_HOME,值为你得zookeeper安装路径:

修改path变量,值为:System Variable%ZOOKEEPER_HOME%\bin;注意不是让你把path得值清空!!!,而是在最前面或者最后面新增!记住每个值要以;隔开.


好了 该配置得配置完毕了,让我们启动服务,进入bin目录下启动zkserver命令,按住shift键,鼠标右键单机,会发现多出一个选择:在此处打开命令,选择它.

如果你看到了这些文字那说明你已经安装成功了,恭喜,Zookeeper已经完成并在端口2181运行。否则请回调到第三步重新来一遍!

当然了还得修改一些东西才可以使用。

1)、进入Kafka配置目录,例如F:\kafka_2.11-0.9.0.1\config,编辑文件“server.properties”

如果一切正常,那么你看到得界面应该是正常,否则请自行百度解决,注意JDK版本必须1.7以上

创建Producer及Consumer来测试服务器,在f:\kafka_2.11-0.9.0.1\bin\windows打开新的命令行。输入下面的命令,回车:

kafka-console-producer.bat --broker-list localhost:9092 --topic test,再打开一个f:\kafka_2.11-0.9.0.1\bin\windows新的命令行。输入下面的命令,回车:

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

 

再producer端输入任意文字,你会发现consumer端都会接收到。

OK Kafka安装就完成了!稍后我会奉上java如何使用,我找找代码,因为代码在公司电脑上,而我现在家!