上面將數(shù)據(jù)從kafka搬運(yùn)到了mysql中，而很多時候，在處理之后也可以繼續(xù)放到kafka中，供下游消費(fèi)。 FlinkKafkaProducer Flink提供了kafka的...
發(fā)簡信
IP屬地：臺灣
-
flink學(xué)習(xí)之六-數(shù)據(jù)持久化to-kafka
-
flink學(xué)習(xí)之四-使用kafka作為數(shù)據(jù)源
上文中基于spring、druid及mysql實(shí)現(xiàn)了基于db的數(shù)據(jù)源，本文使用kafka作為數(shù)據(jù)源。 FlinkKafkaConsumer010 flink中已經(jīng)預(yù)置了kaf...