Kafka学习（1）- kafka单机安装 - 在Windows安装运行

向右看齐 2022-03-29 09:42 298阅读 0赞

摘要：本文主要说明了如何在Windows安装运行Kafka

**目录：**

1.  安装JDK
2.  安装zookeeper
3.  安装kafka
4.  测试
    
    1.  创建主题
    2.  创建生产者
    3.  创建消费者
5.  可视化  
    [kafka可视化客户端工具（Kafka Tool）的基本使用][kafka_Kafka Tool]  
    [Kafka-manager 可视化web界面][Kafka-manager _web]

## ##

### 一、安装JDK ###

过程比较简单，这里不做说明。

最后打开cmd输入如下内容，表示安装成功

![20160903092900940][]

## ##

### 二、安装zookeeper ###

下载安装包：http://zookeeper.apache.org/releases.html\#download

下载后解压到一个目录：

1.  进入Zookeeper设置目录，笔者D:\\Java\\Tool\\zookeeper-3.4.6\\conf
2.  将“zoo\_sample.cfg”重命名为“zoo.cfg”
3.  在任意文本编辑器（如notepad）中打开zoo.cfg
4.  找到并编辑dataDir=D:/Java/Tool/zookeeper-3.4.6/zookeeper\_data
5.  与Java中的做法类似，我们在系统环境变量中添加：
    
    1.  在系统变量中添加ZOOKEEPER\_HOME = D:\\Java\\Tool\\zookeeper-3.4.6
    2.  编辑path系统变量，添加为路径%ZOOKEEPER\_HOME%\\bin;
6.  在zoo.cfg文件中修改默认的Zookeeper端口（默认端口2181）  
    这是本文最终的zoo.cfg文件的内容：
    
        # The number of milliseconds of each tick
        tickTime=2000
        # The number of ticks that the initial 
        # synchronization phase can take
        initLimit=10
        # The number of ticks that can pass between 
        # sending a request and getting an acknowledgement
        syncLimit=5
        # the directory where the snapshot is stored.
        # do not use /tmp for storage, /tmp here is just 
        # example sakes.
        dataDir=D:/Java/Tool/zookeeper-3.4.6/zookeeper_data
        # the port at which the clients will connect
        clientPort=2181
        # the maximum number of client connections.
        # increase this if you need to handle more clients
        #maxClientCnxns=60
        #
        # Be sure to read the maintenance section of the 
        # administrator guide before turning on autopurge.
        #
        # http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
        #
        # The number of snapshots to retain in dataDir
        #autopurge.snapRetainCount=3
        # Purge task interval in hours
        # Set to "0" to disable auto purge feature
        #autopurge.purgeInterval=1
7.  打开新的cmd，输入zkServer，运行Zookeeper。
8.  命令行提示如下：说明本地Zookeeper启动成功  
    ![20160903093442306][]

## ##

### 三、安装与运行Kafka ###

**下载：**

http://kafka.apache.org/downloads.html。注意要下载二进制版本的  
![20160903095658191][]

下载后解压到任意一个目录，笔者的是D:\\Java\\Tool\\kafka\_2.11-0.10.0.1

1.  进入Kafka安装目录，D:\\Java\\Tool\\kafka\_2.11-0.10.0.1
2.  编辑文件“server.properties”
    
    1.  找到并编辑log.dirs=D:\\Java\\Tool\\kafka\_2.11-0.10.0.1\\kafka-log,这里的目录自己修改成自己喜欢的
    2.  找到并编辑zookeeper.connect=localhost:2181。表示本地运行
    3.  Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认端口：2181。
3.  修改config/zookeeper.properties文件
    
        dataDir=D:/Java/Tool/zookeeper-3.4.6/zookeeper_data
        clientPort=2181

**运行：**

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

1.  进入Kafka安装目录D:\\Java\\Tool\\kafka\_2.11-0.10.0.1
2.  按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
3.  现在输入  .\\bin\\windows\\kafka-server-start.bat .\\config\\server.properties  并回车。  
    ![20160903100506319][]

## ##

### 四、测试 ###

上面的Zookeeper和kafka一直打开

**（1）创建主题**

1.  进入Kafka安装目录D:\\Java\\Tool\\kafka\_2.11-0.10.0.1
2.  按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
3.  现在输入  
    .\\bin\\windows\\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic linlin  
    ![20160903100917695][]

注意不要关了这个窗口！

**（2）创建生产者**

1.  进入Kafka安装目录D:\\Java\\Tool\\kafka\_2.11-0.10.0.1
2.  按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
3.  现在输入  
    ![20160903101046274][]

注意不要关了这个窗口！

**（3）创建消费者**

1.  进入Kafka安装目录D:\\Java\\Tool\\kafka\_2.11-0.10.0.1
2.  按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
3.  现在输入  
    ![20160903101120030][]

注意不要关了这个窗口！

然后在第2个窗口中输入内容，最后记得回车

## ##

### 五、遇到的问题 ###

在创建消费者的时候，错误提示创建语句不对需要升级啥的，查了一下说是版本问题，创建消费者的语句变了，然后卸载了下载的最新的kafka，重新换上了教程中的版本就可以了。

[kafka_Kafka Tool]: https://www.cnblogs.com/frankdeng/p/9452982.html
[Kafka-manager _web]: https://blog.csdn.net/qq_41497111/article/details/89552733
[20160903092900940]: /images/20220329/92203ea399fd4eb7849ede3a5f179083.png
[20160903093442306]: /images/20220329/2b600e703aba44f0bd0aef7be45f8685.png
[20160903095658191]: /images/20220329/4fdafa30c15748a4890e59147c60bf64.png
[20160903100506319]: /images/20220329/c7a5d737fe9d4f7ba2ecf66e694d325b.png
[20160903100917695]: /images/20220329/ebf0ec9249964832b2248f6297df6a2d.png
[20160903101046274]: /images/20220329/6d4a3cb34f6348199619f63dd99069cb.png
[20160903101120030]: /images/20220329/a2b99e5ccf434dc2932ce63e912ad688.png