2539 Open source projects that are alternatives of or similar to Go Streams

A Clojure DSL for Kafka Streams

Machine Learning Platform and Recommendation Engine built on Kubernetes

Superman是什么：构建Java 高级开发技术的知识体系，从基础不断打怪升级成为超人之路（更新中.......）

Example end to end data engineering project.

The Refreshingly Simple Cross-Platform C++ Dataflow / Pipelining / Stream Processing / Reactive Programming Framework

Neo4j Kafka Integrations, Docs =>

python通用分布式函数调度框架 pip install function_scheduling_distributed_framework

all kinds of scrapy demo

[https://www.sofineday.com], golang项目开发脚手架,集成最佳实践(gin+gorm+go-redis+mongo+cors+jwt+json日志库zap(支持日志收集到kafka或mongo)+消息队列kafka+微信支付宝支付gopay+api加密+api反向代理+go modules依赖管理+headless爬虫chromedp+makefile+二进制压缩+livereload热加载)

🦄 开源社区系统：基于 SpringBoot + MyBatis + MySQL + Redis + Kafka + Elasticsearch + Spring Security + ... 并提供详细的开发文档和配套教程。包含帖子、评论、私信、系统通知、点赞、关注、搜索、用户设置、数据统计等模块。

M-Lab ingestion pipeline

智能办公OA系统[SpringBoot2-快速开发平台]，适用于医院，学校，中小型企业等机构的管理。Activiti5.22+动态表单实现零java代码即可做到复杂业务的流程实施，同时包含文件在线操作、日志、考勤、CRM、ERP进销存、项目、拖拽式生成问卷、日程、笔记、计划、行政等多种复杂业务功能。同时，可进行授权二开。

Kafka ecosystem ... but step by step!

Collection of Kubernetes Operators built with KUDO.

.NET Stream Processing Library for Apache Kafka 🚀

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

Complex Event Processing on top of Kafka Streams

Serverless Platform for the stateful services

Stream Discovery and Stream Orchestration

Basin is a visual programming editor for building Spark and PySpark pipelines. Easily build, debug, and deploy complex ETL pipelines from your browser

🌹springboot常用框架整合示例，涉及多种网站监控，数据缓存，网络通信，持久层，权限管理，常用工具等

ETL Library for Machine Learning - data pipelines, data munging and wrangling

我的个人技术博客（Python、Django、Docker、Go、Redis、ElasticSearch、Kafka、Linux）

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

StorageTapper is a scalable realtime MySQL change data streaming, logical backup and logical replication service

Redis Streams and PubSub to Server-Sent Event bridge in Go

syncClient，数据实时同步中间件（同步mysql到kafka、redis、elasticsearch、httpmq）！

streaming pipeline with a mutable configuration

Streaming data changes to a Data Lake with Debezium and Delta Lake pipeline

a payment application intended for deployment by the united states treasury

This repository contains the code base for the Open Stream Processing Benchmark.

Stream Processing Made Easy

A high-performance observability data pipeline.

csvplus extends the standard Go encoding/csv package with fluent interface, lazy stream operations, indices and joins.

Streaming Ethereum and Bitcoin blockchain data to Google Pub/Sub or Postgres in Kubernetes

An experimental programming language for data flow

Open Source Phasor Data Concentrator

💻 Learn Bash streams, pipelines and redirection, from beginner to advanced.

Generate beautiful documentation for your data pipelines in markdown format

Cloud Pipelines Editor is a web app that allows the users to build and run Machine Learning pipelines without having to set up development environment.

A lightweight data processing framework for Apache Spark

Spring Boot & Spring Cloud & Spring Security Demo Case（Spring学习示例实战项目）

Distributed KV Streams

Event-Driven microservices with Kafka Streams

Zenko is the open source multi-cloud data controller: own and keep control of your data on any cloud.

WeDataSphere is a financial level one-stop open-source suitcase for big data platforms. Currently the source code of Scriptis and Linkis has already been released to the open-source community. WeDataSphere, Big Data Made Easy!

基于 Spring Boot2、 Jpa、 Spring Security、JWT、redis、Vue的前后端分离的后台管理系统开发平台， 用户管理、菜单管理、角色管理、字典管理、权限控制的方式为RBAC，操作日志、异常日志、接口限流、项目支持数据权限管理，支持一键生成前后端代码（支持在线预览及打包下载），支持前端菜单动态路由 可一键部署服务器应用，数据库。系统中活跃用户状态监控，监视当前系统CPU、内存、磁盘、堆栈等相关信息,基于Element UI在线表单设计及生成Vue代码。

基于Gradle构建，使用SpringBoot在各个场景的应用，包括集成消息中间件、前后端分离、数据库、缓存、分布式锁、分布式事务等

全栈工程师手册

Web tool for Kafka Connect |

Test your code without writing mocks with ephemeral Docker containers 📦 Setup popular services with just a couple lines of code ⏱️ No bash, no yaml, only code 💻

Surging is a micro-service engine that provides a lightweight, high-performance, modular RPC request pipeline. The service engine supports http, TCP, WS,Grpc, Thrift,Mqtt, UDP, and DNS protocols. It uses ZooKeeper and Consul as a registry, and integrates it. Hash, random, polling, Fair Polling as a load balancing algorithm, built-in service gove…

C++ Parallel Computing and Asynchronous Networking Engine

Kasper is a lightweight library for processing Kafka topics.

NetDiscovery 是一款基于 Vert.x、RxJava 2 等框架实现的通用爬虫框架/中间件。

The database purpose-built for stream processing applications.

SpringBoot框架源码实战（已更新到springboot2版本实现）~基本用法，Rest，Controller，事件监听，连接数据库MySQL，jpa，redis集成，mybatis集成（声明式与xml两种方式~对应的添删查改功能），日志处理，devtools配置，拦截器用法，资源配置读取，测试集成，Web层实现请求映射，security安全验证，rabbitMq集成，kafka集成，分布式id生成器等。项目实战：https://github.com/hemin1003/yfax-parent 已投入生产线上使用

Real-time messaging library for Go with scalability in mind

Ship changes in Postgres 🐘 to Kafka 📖

Kafka client for functional streams for scala (fs2)