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

A list about Apache Kafka

equivalent to kafka-streams 🐙 for nodejs ✨🐢🚀✨

Fancy stream processing made operationally mundane

istio 微服务示例代码 grpc+protobuf+echo+websocket+mysql+redis+kafka+docker-compose

Python Stream Processing

Airbyte is an open-source EL(T) platform that helps you replicate your data in your warehouses, lakes and databases.

Machine is a workflow/pipeline library for processing data

A simple and eloquent workflow for streaming messages to micro-services.

Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.

Data Accelerator for Apache Spark simplifies onboarding to Streaming of Big Data. It offers a rich, easy to use experience to help with creation, editing and management of Spark jobs on Azure HDInsights or Databricks while enabling the full power of the Spark engine.

An extensible Java framework for building XML and non-XML streaming applications

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

Kafka Tutorials microsite

Source code for the Kafka Streams in Action Book

Demo applications and code examples for Confluent Platform and Apache Kafka

spring、spring-boot、spring-cloud 常用整合用例

High performance data aggregating storage

A high performance/ real-time C++ Kafka streams framework (C++17)

Open-Source Web GUI for Apache Kafka Management

The magic message bus

A graphical user interface for distributed data processing of high throughput genomics

⚙️ Schedule notebooks, run them like APIs, expose securely your assets: Jupyter as a viable ⚡️ Production environment

Stream Processing Made Easy

⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.

Extensible stream pipelines with object algebras.

A curated list of awesome big data frameworks, ressources and other awesomeness.

🇨🇳 MyDataHarbor是一个致力于解决任意数据源到任意数据源的分布式、高扩展性、高性能、事务级的数据同步中间件。帮助用户可靠、快速、稳定的对海量数据进行准实时增量同步或者定时全量同步，主要定位是为实时交易系统服务，亦可用于大数据的数据同步（ETL领域）。

a payment application intended for deployment by the united states treasury

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

Scalable real-time messaging server in a language-agnostic way. Set up once and forever.

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

Open Source Phasor Data Concentrator

Generate beautiful documentation for your data pipelines in markdown format

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

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

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

M-Lab ingestion pipeline

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

Complex Event Processing on top of Kafka Streams

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

dnc 去中心化 开源社区 轻联盟 dncto.com QQ群 779699538

Event-Driven microservices with Kafka Streams

Stream Discovery and Stream Orchestration

Distributed KV Streams

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

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

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

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

分布式架构开发套件。包括缓存(一二级缓存、自动缓存管理)、队列、分布式定时任务、文件服务(七牛、阿里云OSS、fastDFS)、日志、搜索、分布式锁、分布式事务、集成dubbo、spring boot支持以及常用的工具包等。

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

An experimental programming language for data flow

全栈工程师手册

Web tool for Kafka Connect |

C++ Parallel Computing and Asynchronous Networking Engine

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…

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!