在windows上搭建 kafka

迈不过友情╰ 2023-07-02 12:23 148阅读 0赞

## 安装jdk ##

下载jdk并安装后进行验证，安装成功，此处不详细叙述

## 下载kafka ##

下载地址  http://kafka.apache.org/downloads.html
      本次演示版本为 kafka-2.3.0

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmdqaWUxNjE2_size_16_color_FFFFFF_t_70]

## windows 启动zookeeper ##

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

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmdqaWUxNjE2_size_16_color_FFFFFF_t_70 1]

## windows 启动Kafka ##

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

#### 伪分布式环境部署 ####

1.  将 \\kafka\_2.12-2.3.0\\config\\server.properties 文件复制两份分别命名为 server-1.properties、server-2.properties
2.  在 server-1.properties 文件中修改配置如下：
    
        broker.id=0
        	listeners=PLAINTEXT://:9092
        	log.dirs=/tmp/kafka-logs
        	```
        改为
    
        broker.id=1
         listeners=PLAINTEXT://:9093
         log.dirs=/tmp/kafka-logs-1
         ```
3.  在 server-2.properties 文件中修改配置如下：
    
        broker.id=0
        	listeners=PLAINTEXT://:9092
        	log.dirs=/tmp/kafka-logs
        	```
        改为
    
        broker.id=2
         listeners=PLAINTEXT://:9093
         log.dirs=/tmp/kafka-logs-2
         ```

**一台机器上启动多个KafkaServer来达到多代理的效果，因此必须保证broker.id及port在同一台机器上的多个server.properties 中唯一。**

启动伪分布式

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

## 创建topic ##

kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

## 查看topic ##

kafka-topics.bat --list --bootstrap-server localhost:9092

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmdqaWUxNjE2_size_16_color_FFFFFF_t_70 2]

## 生产者 发送消息 ##

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

![在这里插入图片描述][20200130001104374.png]

### 消费者 接收消息 ###

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

![在这里插入图片描述][20200130001318780.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmdqaWUxNjE2_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200129232758379.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmdqaWUxNjE2,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmdqaWUxNjE2_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200129233225790.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmdqaWUxNjE2,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmdqaWUxNjE2_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200130001612534.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmdqaWUxNjE2,size_16,color_FFFFFF,t_70
[20200130001104374.png]: https://img-blog.csdnimg.cn/20200130001104374.png
[20200130001318780.png]: https://img-blog.csdnimg.cn/20200130001318780.png