: LocationStrategy,位置策略,直接使用源码推荐的优先一致性策略即可,在大多数情况下,它将一致地在所有执行器之间分配分区
// consumerStrategy: ConsumerStrategy...[K, V],消费策略,直接使用源码推荐的订阅模式,通过参数订阅主题即可
//kafkaDS就是从Kafka中消费到的完整的消息记录!
...: LocationStrategy,位置策略,直接使用源码推荐的优先一致性策略即可,在大多数情况下,它将一致地在所有执行器之间分配分区
// consumerStrategy: ConsumerStrategy...[K, V],消费策略,直接使用源码推荐的订阅模式,通过参数订阅主题即可
//kafkaDS就是从Kafka中消费到的完整的消息记录!
...offset信息,所以从auto.offset.reset配置的latest开始消费")
KafkaUtils.createDirectStream[String, String](