1183 Open source projects that are alternatives of or similar to Kafka Flow

Command Dispatcher, Processor, and Distributed Task Queue

♠️ C# to JavaScript compiler. Write modern mobile and web apps in C#. Run anywhere with Bridge.NET.

The Apache Kafka Client SDK

.NET project templates with batteries included, providing the minimum amount of code required to get you going faster.

Kafka library in Go

KMinion is a feature-rich Prometheus exporter for Apache Kafka written in Go. It is lightweight and highly configurable so that it will meet your requirements.

A powerful C# library for Razer Chroma's SDK

https://github.com/Eastrall/Sylver

.NET server implementation of the Tus protocol for resumable file uploads. Read more at https://tus.io

Provides a service to install NuGet packages into a Unity project via the Unity Package Manager

A list of tools to extend the .NET Core command line (dotnet)

Stock indicator technical analysis library package for .NET. Send in historical price quotes and get back desired technical indicators. Nothing more. It can be used in any market analysis software using standard OHLCV price quotes for equities, commodities, forex, cryptocurrencies, and others. We had private trading algorithms, machine learning, and charting systems in mind when originally creating this community library. Current indicators include: Accumulation/Distribution Line (ADL), Aroon Oscillator, Arnaud Legoux Moving Average (ALMA), Average Directional Index (ADX), Average True Range (ATR), Awesome Oscillator (AO), Balance of Power (BOP), Beta Coefficient, Bollinger Bands®, Chaikin Money Flow (CMF), Chaikin Oscillator, Chandelier Exit, Choppiness Index (CHOP), Commodity Channel Index (CCI), ConnorsRSI, Correlation Coefficient, Donchian Channels, Double Exponential Moving Average (DEMA), Elder-ray Index, Exponential Moving Average (EMA), Force Index, Fractal Chaos Bands (FCB), Gator Oscillator, Heikin-Ashi, Hull Moving Average (HMA), Ichimoku Cloud, Kaufman's Adaptive Moving Average (KAMA), KDJ Index, Keltner Channels, Momentum Oscillator, Money Flow Index (MFI), MESA Adaptive Moving Averages (MAMA), Moving Average Convergence/Divergence (MACD), Moving Average Envelopes, On-balance Volume (OBV), Parabolic SAR (stop and reverse), Percentage Volume Oscillator (PVO), Pivot Points and Rolling Pivot Points, Price Channels, Price (Comparative) Relative Strength (PRS), Price Momentum Oscillator (PMO), Rate of Change (ROC), Relative Strength Index (RSI), R-Squared (Coefficient of Determination), Simple Moving Average (SMA), Slope and Linear Regression, Smoothed Moving Average (SMMA), Standard Deviation, Stoller Average Range Channel (STARC) Bands, Stochastic Oscillator, Stochastic RSI, SuperTrend, Tillson T3 Moving Average, Triple Exponential Moving Average (TEMA), Triple EMA Oscillator (TRIX), True Strength Index (TSI), Ulcer Index, Ultimate Oscillator, Volume Simple Moving Average, Volume Weighted Average Price (VWAP), Vortex Indicator (VI), Weighted Moving Average (WMA), Williams %R, Williams Alligator, Williams Fractal, and Zig Zag.

.NET 5 Nuget Packages.

An Hexagonal Architecture with DDD + Aggregates + Event Sourcing using .NET Core, Kafka e MongoDB (Blog Engine)

Kafka consumer lag-checking application for monitoring, written in Scala and Akka HTTP; a wrap around the Kafka consumer group command. Integrations with Cloudwatch and Datadog. Authentication recently added

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]

Automagically update nuget packages in .NET projects

NuGet server and cache running on kestrel in docker

A community-developed, free, open source, microservices API automation and load testing framework built using JUnit core runners for Http REST, SOAP, Security, Database, Kafka and much more. Zerocode Open Source enables you to create, change, orchestrate and maintain your automated test cases declaratively with absolute ease.

QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景； 也包括报价搜索等高吞吐量场景。

PHP queue worker and consumer - Ready for AWS SQS, Redis, Beanstalkd and others.

Log exception details and custom properties that are not output in Exception.ToString().

🎩 Most advanced high level Node.js Kafka client

weiboAd Infrastructure Data Processor : kafka consumer embedded Lua scripting language in data process framework

微信全平台 SDK Senparc.Weixin for C#，支持 .NET Framework 及 .NET Core、.NET 6.0。已支持微信公众号、小程序、小游戏、企业号、企业微信、开放平台、微信支付、JSSDK、微信周边等全平台。 WeChat SDK for C#.

Another app which used to monitor the progress of Kafka Producer and Consumer

Confluent's Apache Kafka .NET client

Google reCAPTCHA v2/v3 for .NET Core 3.x

A scripting language for .NET Core

The Apache Kafka C/C++ library

CodeIgniter 3 Daemon Queue Worker (Consumer) Management Controller

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

📦 GitHub action to automate publishing NuGet packages when project version changes

Sample Event Sourcing implementation with .NET Core

.NET Core Extensions and Helper NuGet packages.

A .NET 5 library to run C# code in parallel on the GPU through DX12 and dynamically generated HLSL compute shaders, with the goal of making GPU computing easy to use for all .NET developers! 🚀

RabbitMQ Extension for Yii2

✅ Commad-Line Task management with storage on your GitHub 🔥

NsDepCop is a static code analysis tool that helps to enforce namespace dependency rules in C# projects. No more unplanned or unnoticed dependencies in your system.

C# WinForm UI/UX Component Library

Statsd C# Client

Symfony2/3/4/5 Queue Bundle (for background jobs) supporting Mongo (Doctrine ODM), Mysql (and any Doctrine ORM), RabbitMQ, Beanstalkd, Redis, and ... {write your own}

Do heavy data process outside of your UI JS thread.

Confluent Schema Registry for Kafka

Bireme is an incremental synchronization tool for the Greenplum / HashData data warehouse

Distributed Java game server, including login, gateway, game demo

Cloudflare Workers

EF Core is a modern object-database mapper for .NET. It supports LINQ queries, change tracking, updates, and schema migrations.

Data structures and algorithms for .NET

Serverless provider plugin for Cloudflare Workers

This is the demo application that i created for my talk 'Microservice Architecture & Implementation with Asp.Net Core' at Dotnet İstanbul Meetup Group.

Golang Kafka consumer and producer example

Aspect-based architectural framework for .NET business applications involving some FP and CQRS principles.

一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

The AsyncAPI specification allows you to create machine-readable definitions of your asynchronous APIs.

A .NET library to access files and directories with more than 260 characters length.

Machine Learning Platform and Recommendation Engine built on Kubernetes

syslog-ng is an enhanced log daemon, supporting a wide range of input and output methods: syslog, unstructured text, queueing, SQL & NoSQL.

This repo contains code samples using .NET Core, which run on Windows, Mac OS and Ubuntu.