Tributary is a lightweight event streaming platform built in Java that enables asynchronous communication between distributed system components. It implements core messaging patterns with support for topics, partitions, producers, and consumer groups.
- Topic-based message organization
- Partitioned message queues
- Random and manual partition allocation
- Consumer groups with rebalancing
- Message replay functionality
- Thread-safe implementation
- Generic payload support
- Java 17+
- Gradle 8.5
# Build the project
gradle buildgradle runCreate Resources
create topic orders Integer
create partition orders p1
create producer order_producer orders Integer Manual
create consumer group order_group orders Range
create consumer order_group consumer1Produce & Consume Messages
# Produce message
produce event order_producer orders 12345 p1
# Consume message
consume event consumer1 orders p1
# Replay messages
playback consumer1 orders p1 0View Status
show topic orders
show consumer group order_group📚 Documentation
- demostrate.mp4
- design.pdf
- final_uml_diagram.jpg
- initialUMLdiagram.jpg
# Run tests
gradle test
# Generate coverage report
gradle jacocoTestReport