Extensions for DataSource

Requires Kotlin 2.2 or later and JDK 17 or later.

Compatibility

This library is maintained in two parallel lines — choose the version that matches your Spring Boot major version:

Library version	Branch	Spring Boot	Default JSON binding	Kotlin
3.x	main	4.0.x	Jackson 3 (Jackson 2 available via spring-boot-jackson2)	2.2.21+
2.x	springboot-3.5.x	3.5.x	Jackson 2 (Jackson 3 available by adding the tools.jackson dependencies)	2.2+

Upgrading from 2.x (Spring Boot 3.5) to 3.x (Spring Boot 4.0)? See the migration guide.

Reactive

These modules provide APIs for consuming and providing data as streams implementations provided by popular libraries to DataSource subjects and channels.

Module	Supports
datasourcex-kotlin	Kotlin Flow and suspending functions
datasourcex-java-flow	Java Flow
datasourcex-reactivestreams	Reactive Streams such as: Reactor - Flux and Mono RxJava - Observable, Flowable, Single and Maybe

Usage

Add the required dependencies to your project:

dependencies {
implementation("com.caplin.integration.datasourcex:datasourcex-<java-flow|kotlin|reactivestreams>:<version>")
}

Then refer to the documentation:

• datasourcex-reactivestreams
• datasourcex-kotlin
• datasourcex-java-flow

StreamLink

sl4jx-kotlin is a Kotlin Flow-based client wrapper over Caplin's StreamLink and KeyMaster SDKs, for consuming data from a Liberator.

Usage

Add the following dependency to your project:

dependencies {
implementation("com.caplin.integration.datasourcex:sl4jx-kotlin:<version>")
}

Then refer to the documentation.

Spring

This module provides a starter for integrating Caplin DataSource with your Spring Boot 4.0 application, and integration with Spring Messaging for publishing data from annotated functions.

Usage

Add the following dependency to your project:

dependencies {
implementation("com.caplin.integration.datasourcex:spring-boot-starter-datasource:<version>")
}

Then refer to the documentation, hands-on tutorial and examples.

Testing

datasourcex-kotest is a Kotest test-support harness that runs a Liberator in a Testcontainers container for StreamLink client tests.

Usage

Add the following dependency to your project:

dependencies {
testImplementation("com.caplin.integration.datasourcex:datasourcex-kotest:<version>")
}

Then refer to the documentation.