426 Open source projects that are alternatives of or similar to Tsujun

Kafka input and output plugin for Fluentd

Avro SerDe for Apache Spark structured APIs.

Kafka Development Tool

Python Stream Processing. A Faust fork

Divolte Collector

Neo4j Kafka Integrations, Docs =>

Rust client for Apache Kafka

Azure Event Hubs for Apache Kafka Ecosystems

Terraform provider for managing Apache Kafka Topics + ACLs

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

Kubernetes Universal Declarative Operator (KUDO)

Asp.Net Core 5 Clean Architecture (Microservices, Modular Monolith, Monolith) samples (+Blazor, Angular 11, React 17, Vue 2.6), Domain-Driven Design, CQRS, Event Sourcing, SOLID, Asp.Net Core Identity Custom Storage, Identity Server 4 Admin UI, Entity Framework Core, Selenium E2E Testing, SignalR Notification, Hangfire Tasks Scheduling, Health Checks, Security Headers, ...

全栈工程师手册

A complete example of a big data application using : Kubernetes (kops/aws), Apache Spark SQL/Streaming/MLib, Apache Flink, Scala, Python, Apache Kafka, Apache Hbase, Apache Parquet, Apache Avro, Apache Storm, Twitter Api, MongoDB, NodeJS, Angular, GraphQL

Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.

本项目已迁移至 github.com/jetlinks

Load data from Kafka to any data warehouse

Kafka-based Job Queue for Python

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

Kafka Source Connector For Oracle

docker compose files to create a fully working kafka stack

Very simplified shop sales system made in a microservices architecture using quarkus

Kafka Docker for development. Kafka, Zookeeper, Schema Registry, Kafka-Connect, Landoop Tools, 20+ connectors

Kafka, Debezium and Fuse demonstration based on Chuck Norris movies!

Real Time Analytics and Data Pipelines based on Spark Streaming

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

Library offering http based query on top of Kafka Streams Interactive Queries

❤for real-time DataOps - where the application and data fabric blends - Lenses

A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernetes deployed on the cloud

This repo contains my notes on working with Go and computer systems.

Demonstrations for Kafka with Spring Boot

Reliable messages resolve distributed transactions

golang版本的hangout, 希望能省些内存. 使用了自己写的Kafka lib .. 虚. 不过我们在生产环境已经使用近1年, kafka 版本从0.9.0.1到2.0都在使用, 目前情况稳定. 吞吐量在每天2000亿条以上.

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

Kafka Streams based microservice

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

大数据学习，从零开始学习大数据，包含大数据学习各阶段学习视频、面试资料

Redis Kafka Streams State Store

An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.

Apache Kafka client library for Erlang/Elixir

This is a Platform that collects all the data accuring in your Application and shows the data in real time by using Kibana or other tools.

Kafka with KafkaReactor and Kafka Streams Examples in Kotlin

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

Spring Boot application showing basic configuration to work with Kafka

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

Command Dispatcher, Processor, and Distributed Task Queue

Oh no! Yet another Kafka operator for Kubernetes

《Kafka技术内幕》代码

Event Sourcing(CQRS) and Materialized views with Kafka Streams

Kafka command line tool that likes JSON

Web tool for Avro Schema Registry |

Kafka web UI

Write your Spark data to Kafka seamlessly

A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka

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

light, fast, scalable, streaming microservices made easy

Twitter Streaming API Example with Kafka Streams in Scala

Collection of Kubernetes Operators built with KUDO.

Kafka Akka.Streams connectors - part of the Alpakka project

450+ AWS, Hadoop, Cloud, Kafka, Docker, Elasticsearch, RabbitMQ, Redis, HBase, Solr, Cassandra, ZooKeeper, HDFS, Yarn, Hive, Presto, Drill, Impala, Consul, Spark, Jenkins, Travis CI, Git, MySQL, Linux, DNS, Whois, SSL Certs, Yum Security Updates, Kubernetes, Cloudera etc...