Hi dev, Currently I have a scenario where I am reading the data from Kafka using spark dataframe.
Multiple data sources ingest the data into kafka same topic. My dataframe now has got json string from multiple sources. I have got key column from Kafka which can be used to identify which source data value it is. In spark how can I now apply the schema dynamically using the key colum value. Any help would be appreciated. Thanks and Regards Rahul
