前言

这四个组件，都既能做kafka的生产者，也能做消费者。

这里挑flink和springBoot详细介绍。其他两个详见视频教程。

一、与Flink的集成

1.1 Flink生产者

引入maven包

写FlinkKafkaProducer1类

注意：系统本身已经有了FlinkKafkaProducer类了...因此这里非常容易冲突，要在后面加个1

1.2 Flink消费者

二、与SpringBoot的集成