部署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 流式计算