网站介绍：文章浏览阅读223次。# -*- coding: utf-8 -*-""" @CreateTime :2021/1/5 15:26 @Author : Liangde @Description : @Modify:"""from pyspark import SparkConffrom pyspark.sql import SparkSessionfrom conf.setting import KAFKA_CONFIG""" 设置任务 常量 lost data 异常应_pyspark 读取kafka数据 将数据分为两个流 写入不同的kafka中
- 链接地址：https://blog.csdn.net/Cincinnati_De/article/details/112249626
- 链接标题：pyspark 结构化流读取 两个 kafka主题，累计统计 IP 出现次数 Demo版本_pyspark 读取kafka数据 将数据分为两个流 写入不同的kafka中-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：3380
- 网站标签：pyspark 读取kafka数据 将数据分为两个流 写入不同的kafka中
