优酷网站怎么做的最新军事新闻最新消息
目录
一、前提
1、jdk
2、Zookeeper
2.1、解压
2.2、创建data文件夹
2.3、配置文件
2.4、添加环境变量
2.5、启动zk：zkServer
2.6、客户端
3、Scala
3.1、下载安装
3.2、配置环境变量
3.3、验证是否安装成功
二、kafka下载安装
1、下载
2、安装
2.1、解压
2.2、新建logs目录
编辑 2.3、修改配置文件
2.3.1、修改 log.dirs 参数
2.3.2、修改 listeners 参数
3、启动
4、kafka操作
4.1、创建topic
4.2、查看topic列表
4.3、创建生产者
4.4、创建消费者
4.5、测试收发消息
一、前提
安装Kafka之前，需要安装JDK、Zookeeper、Scala,
本次安装版本选择：
JDK：1.8
Zookeeper：3.6.4
Scala：2.12
Kafka：3.5.2
1、jdk
Java Downloads | Oracle
见jdk下载安装。
2、Zookeeper
下载地址
Apache ZooKeeper
Apache Download Mirrors
下载后安装：
2.1、解压
进入到解压后的文件查看：
2.2、创建data文件夹
2.3、配置文件
（1）进入config目录 ，复制zoo_sample.cfg文件，改名为zoo.cfg，更改zoo_sample.cfg 文件名为 zoo.cfg 的原因为：安装的bin目录下的 zkEnv.cmd文件内指定了使用 zoo.cfg文件。
（若不更改zoo_sample.cfg文件名，也可直接把此文件中的 zoo.cfg 更改为 zoo_sample.cfg）
（2）修改配置文件 zoo.cfg：
把dataDir=/tmp/zookeeper
修改为：
dataDir=D:\\javas\\zk\\apache-zookeeper-3.6.4-bin\\data
注意：此处的路径一定要使用双斜杠" \ "，如果是单斜杠，在启动服务端时会把配置的内容输出到 bin 目录下面）2.4、添加环境变量
①新建环境变量
点击确定
②将新建的环境变量添加到系统变量path中
2.5、启动zk：zkServer
以管理员权限打开cmd命令窗口，输入
zkServer
或者进入到 bin 目录，双击 zkServer.cmd：
2.6、客户端
客户端连接Zookeeper：zkCli，
以管理员权限打开命令窗口，输入：zkCli
3、Scala
3.1、下载安装
下载地址：https://downloads.lightbend.com/scala/2.11.12/scala-2.11.12.msi
下载后按照提示一步步安装，如我安装在
3.2、配置环境变量
（1）新增环境变量%SCALA_HOME%
（2）%SCALA_HOME%\bin添加到path中
3.3、验证是否安装成功
cmd输入：Scala
二、kafka下载安装
version：2.12-3.5.2，表示Scala版本是2.12，Kafka版本是基于此的3.5.2版本。
1、下载
官网下载地址：Index of /kafka/3.5.2 (apache.org)
2、安装
2.1、解压
如我解压到D:\javas\kafka\kafka_2.12-3.5.2
2.2、新建logs目录
2.3、修改配置文件
修改Kafka配置文件 server.properties
文件路径：D:\javas\kafka\kafka_2.12-3.5.2\config\server.properties
2.3.1、修改 log.dirs 参数
修改 log.dirs 参数值，修改成上一步新建的logs文件夹。注意文件夹路径中是双左斜杠
log.dirs=D:\\javas\\kafka\\kafka_2.12-3.5.2\\logs2.3.2、修改 listeners 参数
listeners=PLAINTEXT://localhost:9092
3、启动
（1）启动zk:
由于Kafka依赖于Zookeeper，所以要先启动Zookeeper，cmd输入zkServer即可启动zk。
（2）启动kafka:
管理员权限打开命令窗口，进入到Kafka安装目录（D:\javas\kafka\kafka_2.12-3.5.2）。
输入如下命令启动Kafka服务：
.\bin\windows\kafka-server-start.bat .\config\server.properties
4、kafka操作
Kafka2.2之后版本中使用–zookeeper hadoop01:2181会出现报错情况，2.2之后的版本使用了–bootstrap-server hadoop01:9092来替换–zookeeper hadoop01:2181。
以下命令均在D:\javas\kafka\kafka_2.12-3.5.2\bin\windows目录下：
4.1、创建topic
cmd打开一个新窗口：
kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
4.2、查看topic列表
kafka-topics.bat --bootstrap-server localhost:9092 --list
4.3、创建生产者
cmd打开一个新窗口
kafka-console-producer.bat --broker-list localhost:9092 --topic test
4.4、创建消费者
cmd打开一个新窗口
4.5、测试收发消息
（1）在producer（生产者）控制台窗口输入消息：
（2）在consumer（消费者）控制台窗口查看消息：
注意：收不到消息，常见情况
- 在consumer没有打开之前，就在producer里面发送了消息
- producer和consumer使用的topic不一致
三、kafka manager控制台
为了简化开发者和服务工程师维护Kafka集群的工作，yahoo构建了一个叫做Kafka管理器的基于Web工具，叫做 Kafka Manager。这个管理工具可以很容易地发现分布在集群中的哪些topic分布不均匀，或者是分区在整个集群分布不均匀的的情况。它支持管理多个集群、选择副本、副本重新分配以及创建Topic。同时，这个管理工具也是一个非常好的可以快速浏览这个集群的工具，有如下功能：
1.管理多个kafka集群
2.便捷的检查kafka集群状态(topics,brokers,备份分布情况,分区分布情况)
3.选择你要运行的副本
4.基于当前分区状况进行
5.可以选择topic配置并创建topic(0.8.1.1和0.8.2的配置不同)
6.删除topic(只支持0.8.2以上的版本并且要在broker配置中设置delete.topic.enable=true)
7.Topic list会指明哪些topic被删除（在0.8.2以上版本适用）
8.为已存在的topic增加分区
9.为已存在的topic更新配置
10.在多个topic上批量重分区
11.在多个topic上批量重分区(可选partition broker位置)
https://github.com/yahoo/kafka-manager
下载kafka-manager的releases中的最新zip版本： https://github.com/yahoo/kafka-manager/releases