上面我们说了数据的转换处理,数据处理以后,我们经过sink处理,就是进行存储对吧,

这里可以存入csv文件,存入text文件等.

然后我们再来看,我们如何把数据处理完了以后,存入到kafka中,

我们写个测试类SinkTest_Kafka

我们同样从别的地方copy过来,之前的代码,包含

从文件中读取数据,然后,把数据输入流inputStream,通过.map方法,把数据转换成

SensorReading,这个