Mirror of Apache Samza
- scala
- big-data
- samza
Repository Index
47,133 repositories indexed
241–264 of 536 · Most stars
Lua kafka client driver for the Openresty based on the cosocket API
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
- golang
- event-sourcing
- stream-processing
- brokers
Healthcare data infrastructure for next generation care delivery.
- api
- healthcare
- open-source
- soc2
Fast ring-buffer deque (double-ended queue)
- deque
- queue
- ring-buffer
- circular-buffer
📈 Collect customer event data from your apps. (Note that this project only includes the API collector, not the visualization platform)
Polo travels through your database and creates sample snapshots so you can work with real world data in development.
- database
- snapshot
- productivity
- activerecord
Library for exploring and validating machine learning data
The ultimate distributed MQTT broker. Handles 100M+ connections and 10M msg/sec with ease. Built on Kafka to provide industrial-grade persistence and eliminate data loss.
Tenzir is the data pipeline engine for security teams.
- incident-response
- threathunting
- siem
- soc
Essential Spark extensions and helper methods ✨😲
- spark
- dataframe
The repository host gives no description.
- hacktoberfest
mangos is a pure Golang implementation of nanomsg's "Scalablilty Protocols"
- nanomsg
- message
- queue
- nng
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
Lightweight real-time big data streaming engine over Apache Pekko
- akka
- stream-processing
- bigdata
- scala
Performant pure-PHP AMQP (RabbitMQ) sync/async (ReactPHP) library
- amqp
- amqp-client
- amqp0-9-1
- php
Low-code tool for automating actions on real time data | Stream processing for the users.
- flink
- flink-kafka
- apache-flink
- gui
A modern .NET framework for communication over RabbitMq
- rabbitmq
- dotnetcore
- message-bus
- async
Easy pipelines for pandas DataFrames.
The MongoDB Spark Connector
Build realtime Ruby web applications. Created by the fine folks at Poll Everywhere.
HStreamDB is an open-source, cloud-native streaming database for IoT and beyond. Modernize your data stack for real-time applications.
TranslatedOntiCards is an enterprise-oriented AI Data Hub that offers one-stop capabilities around business databases: data source connection, metadata understanding, natural language query, cross-source fusion, data quality inspection, query auditing, data asset management, and more
:surfer: Traceable, extendable and minimalist **event bus** implementation for Elixir with built-in **event store** and **event watcher** based on ETS.
- elixir
- eventbus
- event-sourcing
- eventstore