Using pyspark structured streaming to parse Kafka but getting null
I try to parse Kafka using the code bellow:
How to find if Data Frame has null column or schema is not matching
I have below schema fixed
I try to parse Kafka using the code bellow:
I have below schema fixed