消费策略
setStartFromEarliest()
从最初的数据开始进行消费
setStartFromGroupOffsets() 默认消费策略
读取上次消费者保存的 Offset 信息
setStartFromLatest()
从最新的数据进行消费，忽略Offset 信息
setStartFromSpecificOffsets(Map<KafkaTopicPartition, Long>)
可以在代码中指定每个分区开始读取的Offset 信息
扩展
Flink系列：使用Kafka连接器作为Source数据输入
