У меня есть потоковый код pyspark, который считывает данные сердцебиения с сервера kafka.Я могу...

Я ищу, как читать авро-сообщения, которые имеют сложную структуру, из Kafka, используя потоковую...

Я получаю поток данных в форме: +--+---------+---+----+ |id|timestamp|val|xxx |...