1067 Open source projects that are alternatives of or similar to Flow Pipeline

A protobuf source integration for UE4.

销售系统项目，spring+spring mvc+mybatis+dubbo+kafka+redis+maven

Cloudflare Partner Panel

A gRPC cli interface for easy testing against gRPC servers

Karapace - Your Kafka essentials in one tool

SpringBoot 整合各类框架和应用

This is a NodeJS/Angular 2 frontend UI for Kafka cluster monitoring with Burrow

Kalium: a reactive framework for micro-services

一个仿照牛客网实现的讨论社区，不仅实现了基本的注册，登录，发帖，评论，点赞，回复功能，同时使用前缀树实现敏感词过滤，使用wkhtmltopdf生成长图和pdf，实现网站UV和DAU统计，并将用户头像等信息存于七牛云服务器。

Kafka consumer lag monitor

CloudFlare Dynamic DNS client

Program to extract protobufs compiled for C#

Clickhouse Scala Client with Reactive Streams support

Java implementation of the Tendermint ABCI

An Event Sourcing service template with DDD, TDD and SOLID. It has High Cohesion and Loose Coupling, it's a good start for your next Microservice application.

A Ruby client library for Apache Kafka

Kafkawize : A Self service Apache Kafka Topic Management tool/portal. A Web application which automates the process of creating and browsing Kafka topics, acls, schemas by introducing roles/authorizations to users of various teams of an org.

Apache Kafka Web UI for exploring messages, consumers, configurations and more with a focus on a good UI & UX.

Tabix.io UI

Blockchain data parsing and persisting results

Read SparkSQL parquet file as RDD[Protobuf]

Yet another Web UI for KSQL

Open-source IoT Platform - Device management, data collection, processing and visualization.

Materials (slides and code) for Kafka and Kafka Streams Workshop

Powerful, fast and robust engine for converting 3D models into g-code instructions for 3D printers. It is part of the larger open source project Cura.

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

🗑️ GitHub Action to purge a website's cache via the Cloudflare API

SparkStreaming中利用MySQL保存Kafka偏移量保证0数据丢失

An example implementation of a GopherJS client and a Go server using the Improbable gRPC-Web implementation

Checks using a test string if a Cloudflare DNS bypass is possible using CloudFail.

Ansible Kafka role

💥 A simple multi-purpose connection pool client (Kafka & Hbase & Redis & RMDB & Socket & Http)

softflowd: A flow-based network traffic analyser capable of Cisco NetFlow data export software.

A tool to generate the grpc server code for a contract

Automated documentation for async APIs built with Spring Boot

A library provides consumer/producer to work with kafka, avro and schema registry

http interceptor to hoomanize cloudflare requests

Command line Time tracking and reporting. Built using Go(programming language) and protocol buffers.

This is an example of real time stream processing using Spark Streaming, Kafka & Elasticsearch.

Protobuf integration for actix web

PyPI "netflow" package. NetFlow v9 parser, collector and analyzer implemented in Python 3. Developed and tested with softflowd

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

Tool to ease and automate Apache Kafka cluster configuration management

基于utgard的OPC DA客户端

关于kafka的一些相关使用示例代码。

Mirror of Linkedin's Camus

C++ client library for ClickHouse

Ansible playbook to deploy distributed technologies

Go support for Google's protocol buffers

[DEPRECATED] Docker images for Confluent Platform.

Ship changes in Postgres 🐘 to Kafka 📖

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

A Google Protobuf implementation with enif (Erlang nif).

Tool for capture and parse grpc traffic

Kafka Browser that supports standalone Kafka and Strimzi operator

Files needed to try out KSQL Recipes for yourself

De-/Serialization wrapper for Kafka to accomplish end to end encryption

Automatically Create CNAME records for containers served by Traefik

This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit will be deprecated. See the README.md file for hints to alternative toolkits.