Currently I am getting JSONArray String from Kafka which may be corrupted . I tried defining schema of ArrayType but then how can I get corrupt_record field in dataframe ?
Correct
[{"event":"test","properties":{"p1":"v1"}}]
Corrupt Record
{"corrupt_key":"value"}