Requirement was very different for the client.
They wanted us to transform Oracle data in streaming manner and saved the streaming processed data into Oracle again.
I used kafka to push the data from Oracle and then used structure streaming as a kafka consumer to get the data from kafka broker
Transform the data using structure streaming.
Saved the streaming transformed data into Oracle.