Getting Started - atleon/atleon GitHub Wiki

Before using Atleon, you should be familiar with Reactive Streams and Project Reactor.

Building message processing pipelines with Atleon involves the following steps:

1. Add necessary Atleon dependencies
2. Implement AloStreamConfig and construct the implementation with everything it needs to build/access your message processing resources
3. Extend AloStream and apply your AloStreamConfig to define the message processing pipeline
4. Bind your AloStreamConfig to your AloStream and hook in to your application's lifecycle

Atleon dependencies are available from Maven Central.

Example Maven dependenices look like the following:

<dependencies>
    <dependency>
        <groupId>io.atleon</groupId>
        <artifactId>atleon-core</artifactId>
        <version>${atleon.version}</version>
    </dependency>
    <dependency>
        <groupId>io.atleon</groupId>
        <artifactId>atleon-kafka</artifactId>
        <version>${atleon.version}</version>
    </dependency>
</dependencies>

After adding Atleon dependencies to your project, the next step is to define your processing pipeline(s). See AloStreamConfig and AloStream for more details.

Atleon processing pipelines are typically defined in terms of operations on AloFlux. Common transforms are documented in AloFlux Transforms

After building your stream config and definition, you just need to wire both in to your application's lifecycle. See Application Binding for more details.