在Flink里，已经预定义了kafka connector，使用该connector我们可以读写kafka，并且能实现exactly once的语义。

要使用需要引入相关的maven依赖，在这里，因为读写kafka，就会涉及一个问题，kafka-client和broker的版本兼容问题，不过因为kafka client和broker的双向兼容的良好设计（高版本client api可以兼容低版本的broker），所以flink里一直引用最新的kafka client也是没有问题的，我们知道这回事然后就不必过多去关注了。maven依赖如下：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-kafka</artifactId>
    <version>1.15.4</version>
</dependency>

1. 读取Kafka（即使用Kafka Source）

1）使用示例

Kafka source提供了一个用于构建KafkaSource实例的构建器类(KafkaSourceBuilder<OUT>)，可以使用Ka