High-throughput stream processing with the Java Library for Reactive Streams Ingestion (RSI), Virtual Threads, and the Oracle ATP Database

by Juarez Junior

Introduction

Part 1 in this series introduced the Java Library for Reactive Stream Ingestion (RSI), its API, and Oracle Database Express (XE) as the target database.

Now in Part 2 of this series, we will explore another streaming scenario with RSI and the Oracle Autonomous Transaction Processing (ATP) Database —a fully automated database service optimized to run concurrent transactional workloads.

Besides, we’ll use Java Virtual Threads in combination with the ReactiveStreamsIngestion component. Virtual Threads (JEP 425 — Preview) was released recently as part of JDK 19.

We’ll also use Virtual Threads to create the client calls and simulate a workload.

So without further ado, let’s get started!

Prerequisites

• Java 19
• Your preferred Java IDE — Eclipse, IntelliJ, VS Code
• Java 19 support for your IDE, or you can use a CLI
• Maven

Provisioning an Oracle Autonomous Transaction Processing…