Win10配置安装Kafka

超、凢脫俗 2022-01-23 20:01 412阅读 0赞

### Win10配置安装Kafka ###

*  前提
 *   *   *  jdk
         *  zookeeper
 *  下载
 *  安装
 *  单机
 *   *   *  配置
         *  运行
 *  集群
 *   *   *  配置
         *  运行
 *  附录
 *   *   *  官方文档

# 前提 #

### jdk ###

### zookeeper ###

zookeeper的安装配置见另一篇博文：[https://blog.csdn.net/sndayYU/article/details/90718238][https_blog.csdn.net_sndayYU_article_details_90718238]

# 下载 #

网址：[http://kafka.apache.org/downloads][http_kafka.apache.org_downloads]  
下载：kafka\_2.12-2.2.0.tgz  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NuZGF5WVU_size_16_color_FFFFFF_t_70]

# 安装 #

1.解压到“D:\\programGreen\\kafka\_2.12-2.2.0”  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NuZGF5WVU_size_16_color_FFFFFF_t_70 1]

# 单机 #

### 配置 ###

2.修改配置文件"config/server.properties"下面两个参数值；并在D盘建立目录“D:/programData/kafka/logs”

log.dirs=/programData/kafka/logs
    zookeeper.connect=localhost:2181,localhost:2182,localhost:2183

### 运行 ###

1.启动zookeeper的三台服务器，运行“D:\\programGreen\\zookeeper-3.4.9\\bin”下的zkServer1.cmd、zkServer2.cmd、zkServer3.cmd。  
2.启动kafka

C:\Windows\system32>d:
    
    D:\>cd D:\programGreen\kafka_2.12-2.2.0
    
    D:\programGreen\kafka_2.12-2.2.0>.\bin\windows\kafka-server-start.bat .\config\server.properties

3.创建一个主题，并用客户端发送消息

C:\Windows\system32>d:
    
    D:\>cd D:\programGreen\kafka_2.12-2.2.0
    
    D:\programGreen\kafka_2.12-2.2.0>bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
    
    D:\programGreen\kafka_2.12-2.2.0>.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
    >This is a message
    >This is another message
    >

4.启动消费者，可以看到客户端传来的消息。此时，在客户端输入的消息都将传到消费者端。

C:\Windows\system32>d:
    
    D:\>cd D:\programGreen\kafka_2.12-2.2.0
    
    D:\programGreen\kafka_2.12-2.2.0>.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
    This is a message
    This is another message

# 集群 #

### 配置 ###

1.先参照单机配置  
2.将“D:\\programGreen\\kafka\_2.12-2.2.0\\config”下的server.properties复制3份：server-0.properties、server-1.properties、server-2.properties，并修改其内部分内容，如下

# server-0.properties
    broker.id=0
    listeners=PLAINTEXT://:9092
    log.dirs=/programData/kafka/logs-0

# server-1.properties
    broker.id=1
    listeners=PLAINTEXT://:9093
    log.dirs=/programData/kafka/logs-1

# server-2.properties
    broker.id=2
    listeners=PLAINTEXT://:9094
    log.dirs=/programData/kafka/logs-2

### 运行 ###

1.启动3个节点

C:\Windows\system32>d:
    D:\>cd D:\programGreen\kafka_2.12-2.2.0
    D:\programGreen\kafka_2.12-2.2.0>.\bin\windows\kafka-server-start.bat .\config\server-0.properties &

C:\Windows\system32>d:
    D:\>cd D:\programGreen\kafka_2.12-2.2.0
    D:\programGreen\kafka_2.12-2.2.0>.\bin\windows\kafka-server-start.bat .\config\server-1.properties &

C:\Windows\system32>d:
    D:\>cd D:\programGreen\kafka_2.12-2.2.0
    D:\programGreen\kafka_2.12-2.2.0>.\bin\windows\kafka-server-start.bat .\config\server-2.properties &

2.创建一个复制因子为3的新主题,并运行“describe topics”命令查看哪个经纪人正在做什么

C:\Windows\system32>d:
    D:\>cd D:\programGreen\kafka_2.12-2.2.0
    D:\programGreen\kafka_2.12-2.2.0>.\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 1 --topic my-replicated-topic
    D:\programGreen\kafka_2.12-2.2.0>.\bin\windows\kafka-topics.bat --describe --bootstrap-server localhost:9092 --topic my-replicated-topic
    Topic:my-replicated-topic       PartitionCount:1        ReplicationFactor:3     Configs:segment.bytes=1073741824
            Topic: my-replicated-topic      Partition: 0    Leader: 0       Replicas: 0,1,2 Isr: 0,1,2
    D:\programGreen\kafka_2.12-2.2.0>

3.发布消息

C:\Windows\system32>d:
    D:\>cd D:\programGreen\kafka_2.12-2.2.0
    D:\programGreen\kafka_2.12-2.2.0>.\bin\kafka-console-producer.bat --broker-list localhost:9092 --topic my-replicated-topic
    '.\bin\kafka-console-producer.bat' 不是内部或外部命令，也不是可运行的程序
    或批处理文件。
    D:\programGreen\kafka_2.12-2.2.0>.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic my-replicated-topic
    >Hello mytest!
    >

4.启动消费端，接收消息，可以看到消费端能接收到“Hello mytest!”

D:\programGreen\kafka_2.12-2.2.0>.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --from-beginning --topic my-replicated-topic

5.测试兼容性  
安装官方文档干掉主kafka后，消费者还能接收到消息，但本人测试已不能了—？？？？？

C:\Windows\system32>wmic process where "caption = 'java.exe' and commandline like '%server-1.properties%'" get processid
    ProcessId
    20948
    C:\Windows\system32>taskkill /pid 20948 /f
    成功: 已终止 PID 为 20948 的进程。
    C:\Windows\system32>

# 附录 #

### 官方文档 ###

[http://kafka.apache.org/quickstart][http_kafka.apache.org_quickstart]

[https_blog.csdn.net_sndayYU_article_details_90718238]: https://blog.csdn.net/sndayYU/article/details/90718238
[http_kafka.apache.org_downloads]: http://kafka.apache.org/downloads
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NuZGF5WVU_size_16_color_FFFFFF_t_70]: /images/20220124/cf69ffbb8c6f45be91c1cbdb366778aa.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NuZGF5WVU_size_16_color_FFFFFF_t_70 1]: /images/20220124/251eedbe7e654e92b4cb87be9fc132e4.png
[http_kafka.apache.org_quickstart]: http://kafka.apache.org/quickstart