ceroso/stream

Streaming processing framework, source, channel, sink, support mqtt, Kafka and other components

Stream

English | 中文

Overview

Stream asynchronous message high-performance processing framework, similar to go chan, multi-threaded asynchronous processing of messages, supports batch processing of messages.

Features

• Asynchronous multithreading (fixed thread), support for specifying the number of threads
• Support Kafka, MQTT, RabbitMQ message source and support expansion
• Message processing supports training and random processing
• Message processing support interceptor
• Support Spring Boot

Requirements

Compilation requires JDK 8 and above, Maven 3.2.5 and above.

Integrated

If you use Maven, you just need to add the following dependency in pom.xml:

<dependency>
    <groupId>io.github.wendy512</groupId>
    <artifactId>stream-core</artifactId>
    <version>1.0.1</version>
</dependency>

How to use

Reference Wiki

Examples

• Local queue
• Kafka
• MQTT
• RabbitMQ

License

Stream is based on the Apache License 2.0 agreement, and Stream relies on some third-party components whose open source agreement is also Apache License 2.0.

Contact

• Email：[email protected]
• QQ：214566407