1.1 数据生成方式

使用代码的方式持续的生成数据, 然后写入到 kafka 中.

然后Structured Streaming 负责从 kafka 消费数据, 并对数据根据需求进行分析.