412 Open source projects that are alternatives of or similar to Decaton

This project contains examples which demonstrate how to deploy analytic models to mission-critical, scalable production environments leveraging Apache Kafka and its Streams API. Models are built with Python, H2O, TensorFlow, Keras, DeepLearning4 and other technologies.

Web tool for Kafka Connect |

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.

🚀 Web GUI for Kafka Cluster Management

C++ Parallel Computing and Asynchronous Networking Engine

Event sourcing with kafka and nodejs

Kafka UI and Monitoring Tool

all kinds of scrapy demo

Web tool for Avro Schema Registry |

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

Scala helper modules for operating the Apache Kafka client library (0.9.x - 2.1.0)

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

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

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

Bitnami Docker Image for Kafka

Bro IDS Dockerfile

Get a stream of issues and pull requests for your chosen GitHub repository

golang kafka consumer group

Redpanda is the real-time engine for modern apps. Kafka API Compatible; 10x faster 🚀 See more at vectorized.io/redpanda

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

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, ...

Zeek Analysis Tools (ZAT): Processing and analysis of Zeek network data with Pandas, scikit-learn, Kafka and Spark

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

OpenTracing Instrumentation for Apache Kafka Client

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

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

A library that provides an in-memory Kafka instance to run your tests against.

.NET Stream Processing Library for Apache Kafka 🚀

Ansible playbooks for the Confluent Platform

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

提供各种客户端接入阿里云 消息队列 Kafka 的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热加载)

SpringCloud构建实战、从入门到高级，包含eureka、zuul、gateway、feign、ribbon、hystrix、mq、turbine、nacos、elk、consul、zookeeper、rocketmq、kafka、分布式事务(RocketMq、LCN、Seata)、分库分表(Sharding-JDBC)、分布式锁(Redis、Guava)、jwt、SkyWalking、Zipkin、bootadmin等使用案例

Ansible playbook to deploy distributed technologies

Modern and performant Kafka client library for Ruby based on librdkafka

Kafka input and output plugin for Fluentd

Kafka Browser that supports standalone Kafka and Strimzi operator

Production-ready, stable Kafka client for PHP

Python Stream Processing

Terraform provider for managing Apache Kafka Topics + ACLs

Simple Event Driven Microservices with Spring Cloud Stream

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

💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算)；🚀 支持运行过程中增删topic；🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。

Kafka Source Connector For Oracle

Code and presentation for Strata Model Serving tutorial

Code snippets that demonstrate how to leverage the new Kafka 0.11 APIs

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

A client UI to inspect Kafka topics, consume, produce and much more

Flume NG Canal source

Data syncing in golang for ClickHouse.

Kafka GUI for Apache Kafka to manage topics, topics data, consumers group, schema registry, connect and more...

Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.

mq transaction, tcc, eventually consistency. tx life cycle: all listeners handled, if necessary, produce next message

A simple way to publish messages to Kafka from Ruby applications

Apache Kafka load testing "...basically a cloth bag filled with small jagged pieces of scrap iron"

Kafka web UI

An Hexagonal Architecture with DDD + Aggregates + Event Sourcing using .NET Core, Kafka e MongoDB (Blog Engine)

Syslog Collector written in Go, streams to Kafka 0.8

A cohesive & pragmatic framework of FP centric Scala libraries