Kerala is a distributed event-streaming server built for the modern day. It is robust, lightweight and super fast!

• Produce/Consume - create Topics, then produce and consume them.
• Process - create processors that transform or aggregate event data, and project new Streams with the outputs.
• Distribute - scale & balance your event processors across your cluster.

• JDK 8 or above.

Using the gradle wrapper, you can now run.

$ ./gradlew installDist

This will produce the Kerala daemon binary kerala-server under ./core/build/install/kerala-server/bin

$ ./kerala-server

$ ./kerala-server --cluster :9191,:9292,:9393 --port :9191
$ ./kerala-server --cluster :9191,:9292,:9393 --port :9292
$ ./kerala-server --cluster :9191,:9292,:9393 --port :9393

You can use the Dockerfile OR run via docker-compose:

$ docker-compose up

That will deploy a cluster containing 4 kerala nodes.

You can run unit tests as part of a build:

$ ./gradlew build

Or, you can run them specifically:

$ ./gradlew test [--tests <package>|<regex>|<class-name>]

It is just vanilla Gradle so you can refer to the docs for more usages. If you use Jetbrains IDEA, you can also run the tests within the editor.

Kotlin is our core language and we currently enforce styling via ktlint. ktlint will run automatically on a build task.

And can also run it directly:

$ ./gradlew ktlint

And have the formatting done for you:

$ ./gradlew ktlintFormat

• Kotlin - Structured concurrency w/ coroutines
• gRPC - Server-Server communication
• Raft Consensus - Distributed consensus

Get on board by reading CONTRIBUTING.md guidelines for details on our code of conduct, and the process for submitting pull requests!

We use SemVer. For the versions available, see the tags on this repository.

• djjonno@
• +you – come build something cool

This project is licensed under the MIT License - see LICENSE file for details.

There are numerous uses for event-streaming, here are just a few thing you could use Kerala for:

• Define a Topic of UI Events (PageView, PageScroll, PageSwipe, ButtonClick, TextInput, etc) to analyze customer interaction with your product, to gain insights and optimize your critical customer flows.
• Perform time-series analysis on all kinds of application event streams.
• Create app/system audit streams for retrospective analysis for fraud or unauthorized access use-cases.
• Natively supports CQRS Architectures
• ...

• Release Roadmap
• Docs - Coming Soon