oracle – Flink – Kafka JSON Deserialization

I want to create a flink job that reads record from kafka topic and write it to ORACLE Database. Common sense says that create a custom deserializer from read kafka topic. However this job will be more generic such that user give kafka topic name with argument and job read from that topic and write it to Oracle Database table which will also given by user.

After job starting, I can get the destination oracle db schema but how can i deserialize kafka topic records which schema not known before the job starting?

I tried JSONDeserializationSchema but it was deprecated.