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

High performance sFlow/IPFIX/NetFlow Collector

🥚 Netty实践学习案例，见微知著！带着你的心，跟着教程。我相信你行欧。

Enterprise Network Flow Collector (IPFIX, sFlow, Netflow) from Verizon Media

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

Reliable messages resolve distributed transactions

Confluent Schema Registry for Kafka

A CLI tool for Kafka

Sync data from the other DB to ClickHouse(cluster)

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

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

The high-scalability sFlow/NetFlow/IPFIX collector used internally at Cloudflare.

A swiss army knife CLI tool for interacting with Kafka, RabbitMQ and other messaging systems.

Easily load data from kafka to ClickHouse

a command-line Protobuf parser with Kafka support and JSON output

pmacct is a small set of multi-purpose passive network monitoring tools [NetFlow IPFIX sFlow libpcap BGP BMP RPKI IGP Streaming Telemetry].

深圳地铁大数据客流分析系统🚇🚄🌟

Drain log template miner in Python3

Protobuf converter plugin for Kafka Connect

Golang app to read records from a set of kafka topics and write them to an elasticsearch cluster

A JDBC proxy from ClickHouse to external databases

A bank simulation application using mainly Clojure, which can be used to end-to-end test and show some graphs.

Framework for Apache Kafka based Ruby and Rails applications development.

A real-time data replication platform that "unbundles" the receiving, transforming, and transport of data streams.

Argo Tunnel client

EasyRpc is a simple, high-performance, easy-to-use RPC framework based on Netty, ZooKeeper and ProtoStuff.

golang kafka consumer group

🍩 DNS over HTTPs command-line client

A protobuf source integration for UE4.

Cloudflare Partner Panel

Karapace - Your Kafka essentials in one tool

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

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

CloudFlare Dynamic DNS client

Clickhouse Scala Client with Reactive Streams support

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.

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.

Tabix.io UI

Read SparkSQL parquet file as RDD[Protobuf]

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.

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

Real-time analysis of bitcoin markets with Kafka and Tensorflow Serving

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

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

以Kafka为存储介质，提供异步Http RPC的中间件

Utilize misconfigured DNS and old database records to find hidden IP's behind the CloudFlare network

Kafka client for functional streams for scala (fs2)

Rust implementation of gRPC

Ansible Kafka role

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

Deep Learning UDF for KSQL, the Streaming SQL Engine for Apache Kafka with Elasticsearch Sink Example

Automated documentation for async APIs built with Spring Boot

http interceptor to hoomanize cloudflare requests

Implementation of ClickHouse output for logstash

Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors

Protobuf integration for actix web

CLI utility managing CloudFlare services using CloudFlare API

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

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

Mirror of Linkedin's Camus