上面将数据从kafka搬运到了mysql中,而很多时候,在处理之后也可以继续放到kafka中,供下游消费。 FlinkKafkaProducer Flink提供了kafka的...

IP属地:广东
上面将数据从kafka搬运到了mysql中,而很多时候,在处理之后也可以继续放到kafka中,供下游消费。 FlinkKafkaProducer Flink提供了kafka的...
上文中基于spring、druid及mysql实现了基于db的数据源,本文使用kafka作为数据源。 FlinkKafkaConsumer010 flink中已经预置了kaf...