Но Спарк и не всем подходит, у него понятная область применимости но за рамками это области - очень больно и очень дорого (ну или ждать пока delta engine всем дадут)
Кто-нибудь может помочь разобраться как во Flink из топика можно получить записи в формате GenericData (Avro), используя схему из SchemaRegistry? Что-то совсем залип.... ☹️