成都网站建设设计

将想法与焦点和您一起共享

Windows如何安装运行ApacheKafka

这篇文章主要介绍了Windows如何安装运行Apache Kafka,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。

创新互联公司-成都网站建设公司,专注成都网站建设、成都网站设计、网站营销推广,国际域名空间,虚拟空间,网站托管维护有关企业网站制作方案、改版、费用等问题,请联系创新互联公司

下载所需文件

  • 根据系统OS和CPU架构,在这里下载Server JRE http://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html

  • 在这里下载并安装7-zip http://www.7-zip.org/download.html

  • 在这里下载Zookeeper,并用7-zip解压 http://zookeeper.apache.org/releases.html

  • 在这里下载Kafka并用7-zip解压 http://kafka.apache.org/downloads.html

针对此教程,我们将Zookeeper与Kafka解压到C盘,不过也可以选择其他位置。这里我们要使用完全的zookeeper,而不是用Kafka打包的那个,因为这是一个单节点的Zookeeper实例。也可以运行打包了zookeeper的Kafka,位置在\kafka\bin\windows库中。

安装

A. JDK安装

1.启动JRE安装,选中复选框“修改目标路径”,然后点击安装。

Windows如何安装运行Apache Kafka

2.修改安装目录,文件夹名称中不能有空格,例如:C:\Java\jre1.8.0_xx\(默认情况下是C:\Program Files\Java\jre1.8.0_xx),然后点击下一步。 
3.现在点击控制面板->系统->高级系统设置->环境变量,打开系统环境变量对话框。 
4.点击用户变量中的新用户变量按钮,然后在变量名称那里输入JAVA_HOME,并将自定义的jre路径填入变量值。如下图所示:

Windows如何安装运行Apache Kafka

8.确认Java安装打开cmd,输入类型“java –version”,应该能够看到刚刚安装的java版本。

Windows如何安装运行Apache Kafka

恭喜,Zookeeper已经完成并在端口2181运行。

C. 安装Kafka

1. 进入Kafka配置目录,例如C:\kafka_2.11-0.9.0.0\config 
2. 编辑文件“server.properties” 
3. 找到并编辑“log.dirs=/tmp/kafka-logs” to “log.dir= C:\kafka_2.11-0.9.0.0\kafka-logs” 
4. 如果Zookeeper在某些其他的机器或集群上运行,可以将“zookeeper.connect:2181”修改为自定义IP与端口。在这个演示中我们使用了同一个机器,因此没必要做修改。文件中的Kafka端口和broker.id也是可以配置的。其他设置不变。 
5. Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181。

D. 运行Kafka服务器

重要:请确保在启动Kafka服务器前,Zookeeper实例已经准备好并开始运行。

1.进入Kafka安装目录C:\kafka_2.11-0.9.0.0\ 
2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。 
3.现在输入.\bin\windows\kafka-server-start.bat .\config\server.properties 并回车。

.\bin\windows\kafka-server-start.bat .\config\server.properties

Windows如何安装运行Apache Kafka

5.现在Kafka已经准备好并开始运行,可以创建主题来存储消息了。我们也能从Java/Scala代码中,或直接从命令行中生成或使用数据。

E. 创建主题

1. 现在创建主题,命名为“test”,replication factor=1(因为只有1个Kafka服务器在运行)。如果集群中所运行的Kafka服务器不止1个,可以相应增加replication-factor,从而提高数据可用性和系统容错性。 
2. 在C:\kafka_2.11-0.9.0.0\bin\windows打开新的命令行。 
3. 输入下面的命令,回车:

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

Windows如何安装运行Apache Kafka

6.在producer命令行中任意输入内容,回车;在其他consumer命令行中能看到相应消息。

图片描述

7.如果能够将消息推送到consumer端并显示出来的话,Kafka安装就完成了。

一些有用的命令:

cd /home/work/soft/kafka_2.8.0-0.8.1.1/bin

./kafka-topics.sh --create --zookeeper 10.48.170.26:2181 --replication-factor 1 --partitions 3 --topic test          
./kafka-console-producer.sh --broker-list 10.48.170.26:9092 --topic test
./kafka-console-consumer.sh --zookeeper 10.48.170.26:2181 --topic test

1.列出主题:./kafka-topics.sh --list --zookeeper 10.48.170.26:2181 
2.描述主题:./kafka-topics.sh --describe --zookeeper 10.48.170.26:2181 --topic [Topic Name] 
3.从头读取消息:./kafka-console-consumer.sh --zookeeper 10.48.170.26:2181 --topic [Topic Name] --from-beginning 
4.删除主题:./kafka-run-class.sh kafka.admin.TopicCommand --delete --topic [topic_to_delete] --zookeeper 10.48.170.26:2181

感谢你能够认真阅读完这篇文章,希望小编分享的“Windows如何安装运行Apache Kafka”这篇文章对大家有帮助,同时也希望大家多多支持创新互联,关注创新互联行业资讯频道,更多相关知识等着你来学习!


当前文章:Windows如何安装运行ApacheKafka
分享路径:http://chengdu.cdxwcx.cn/article/ppoeis.html