{"repo":"runreveal/kawa","free":true,"listed":false,"github":"https://github.com/runreveal/kawa","clone":"git clone https://github.com/runreveal/kawa.git","description":"A blazingly fast event stream processing library powering the reveald event processing daemon.","language":"Go","stars":149,"topics":["events","go","golang","logs","message-queue","stream-processing"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"kawa    --- kawa (\"Kaa-Wah\") is an opinionated framework for scalable, reliable stream processing. Installation Kawa Add the library to your project as you would any other Go library: Design and Rationale See https://blog.runreveal.com/kawa-the-event-processor-for-the-grug-brained-developer/ Roadmap - Ensure that consumers of kawa aren't subject to all the dependencies of the plugins. - Event Routing and/or Multiple Processors in kawa program - Dynamic Sources (e.g. Kafka Consumer Groups) Disclaimer This is nascent software, subject to breaking changes as we reach a good working set of APIs, interfaces and data models. Please try it out and help shape the direction of the project by giving us feedback! Development & Extension The source and destination interfaces are designed for simplicity of use and implementation. It should be easy to use the sources and destinations in an abstract manner without knowing the underlying implementation, and it should be relatively easy to implement sources and destinations of various types. The library provides multiple abstractions suitable for different purposes. The easiest way to get started is by using the polling/batch implementations for sources/destinations, respectively, since they require less overhead in terms of accounting for offset tracking to ensure at-least-once reliable processing. Extensions under the x package provide either generic or []byte based sources, destinations and utility functions which aren't part of ","default_branch":null,"files":null,"tree":[],"storefront":"/r/runreveal","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/runreveal/kawa/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}