Spring Boot 之 Kafka

Posted 2022-06-04 zd540

Kafka是一个分布式的流平台，具有以下功能：
1.发布和订阅消息。
2.以容错的方式存储消息流。
3.实时的流处理。

主要的两大应用：
1.作为实时的流数据通道，在应用程序之间传递消息。
2.构建实时流处理，对数据流进行转换或反应。

四个核心的API:
Producer API(输出向),Consumer API（输入向）,Streams API（输入&&输出向）,Connector API（输入||输出向）

https://www.orchome.com/5

Kafka的安装：
https://blog.csdn.net/m0_37738114/article/details/80405068
https://blog.csdn.net/zajbetterme/article/details/84553594
安装zookeeper会报无法找到主类错误，换用低版本的
kafka报无法识别 zookeeper命令，使用新版本的命令

spring boot 与kafka的整合:
1.引入依赖
2.在配置文件中配置spring.kafka......
3.创建生产者
4.配置消费者组件（component），注意需指明消费组。