Windows下Kafka快速入门级部署

部署kafka

1、下载Kafka:https://kafka.apache.org/downloads

2、启动Zookeeper与kafka-server

在windows下打开cmd或者powershell,进入到kafka的部署目录并执行启动zookeeper

cd D:\tools\kafka_2.12-3.3.1\

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

新开启一个cmd或powershell窗口,启动kafka-server

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

3、简简单单创建一个主题

bin\windows\kafka-topics.bat --create --topic quickstart-events --bootstrap-server localhost:9092

查看主题的相关信息

bin\windows\kafka-topics.bat --describe --topic quickstart-events --bootstrap-server localhost:9092

配置分区数量,修改config/server.properties文件中的num.partitions=1 默认只有1个分区。

kafka的消息数据是直接存储在磁盘上的,传统思维认为磁盘存储的效率非常低,但是kafka采用顺序写入,他的磁盘写入效率在合理的的磁盘架构下是非常高的。
由于存储在磁盘不消耗内存很多内存,仅仅需要几个缓冲区和线程的的配置,可以说配置是非常简单了。

4、投递消息到kafka主题

启动生产者的控制台

bin\windows\kafka-console-producer.bat --topic quickstart-events1 --bootstrap-server localhost:9092

启动消费者的控制台

bin\windows\kafka-console-consumer.bat --topic quickstart-events1 --from-beginning --bootstrap-server localhost:9092

这样在跑起来了后,就能在生产者端发送消息,然后消费者端消费消息。

kafka Stream 流式计算

来源: 雨林博客(www.yl-blog.com)