kafka

Kafka backend for processing device data

容器日志搜集套件。

Enterprise Service Bus - Java

Open Source data and event driven real time Monitoring and Analytics Platform

Spring Cloud Stream Transactional Messaging Extension

Credit card fraud detection using kafka,scikit,flask,cassandra

ART is a kit of modules for developing multifunctional Java applications

a Kafka connector for copying data between Kafka and Elasticsearch, and create the Elasticsearch index daily

Rsyslog server with multiple input listeners (UDP/TCP/RELP) and outputs (file/kafka/syslog).

scaffold是一个基于Yii2高级项目模版工程化实现的应用程序

Apache Kafka / Confluent KSQL REST Client for PHP

Real-time message streaming over a Hazelcast in-memory data grid

An example showing how to integrate Apache Kafka with Akka Streams and Akka HTTP.

Collection of different demo applications using Apache Spark

Example to show how to deploy kafka dependent scala microservice with docker

Spark1.6和spark2.2的示例，包含kafka,flume,structuredstreaming,jedis,elasticsearch,mysql,dataframe

Managing Kafka topics through annotations in Kubernetes / OpenShift pods

Learn & Practie（学习与实践）

Client libraries to interact with Onesait Platform Cloud Side (Digital Broker specially)

Simple news creation and retrieval application with Hexagonal Architecture using Golang, Kafka, ElasticSearch, Redis and MySQL

Benchmarking tools for Watermill.

A streamlined wrapper around node-rdkafka made with independent composable parts.

An example of streaming microservices with Apache Kafka and Data Flow Topology integration with Lenses Ⓡ DataOps Platform. You can see it in action he...

Ecommerce demo microservice platform, a proof of concept for microservices architecture

Python Kafka consumer - Change Data Capture from MongoDB to MySQL

Simple application implementing Change Data Capture using Kafka Streams.

A kafka monitor to send alarm emails

Web hooks for message queues

Covid19 India Patients Analyzer and Telegram Bot

A tiny wrapper around https://github.com/Shopify/sarama topic and consumer 🚌

the Go client to use Kafka . Based on sarama and sarama-cluster.

Puppet Module for installing and configuring the Confluent Platform

Template for Akka Streams & Kafka. Default impl: mirror a topic onto another one

An opinionated clojure framework for writing kafka machines