What this sample helps you learn
This sample demonstrates how to stream Oracle AI Database serialized JSON data (OSON) using the kafka-clients compatible OKafka client. The application publishes OSON-serialized events into an Oracle AI Database Transactional Event Queue (TxEventQ) topic and consumes them back into typed Java objects, showcasing an end-to-end JSON pub/sub workflow.
Highlights
- An Application class that creates an OKafka topic, publishes sample JSON payloads serialized with Oracle OSON, and consumes them back via the OKafka consumer API.
- A reusable OSON serializer/deserializer built on Oracle's JSONB binding so you can work with plain Java POJOs while benefiting from Oracle's binary JSON format.
- Integration tests powered by Testcontainers that spin up Oracle AI Database Free, provision the TxEventQ topic, and validate the producer/consumer loop.