kafka

Choreography-based sagas to maintain data consistency in a microservice architecture.

大数据生态解决方案基础平台: 搜索系统、公共系统、任务管理系统、数据binlog采集、基础爬虫系统、数据传输系统、运维告警系统、APM、报表系统

Catenae 2 – Microservices Framework for Kafka

:cloud: nodejs kafka connect connector for Google BigQuery

Kafka streams microservice on Docker

Kafka docker image, ready for k8s and openshift clusters

MySQL to NoSQL real time dataflow

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

A Real-time Apache log monitor using Kafka & Spark Streaming, with fake log generator.

Minikube for big data with Scala and Spark

Enhancing Kafka security, PlainSaslServer with LDAP binding and SimpleAclAuthorizer with LDAP group membership

Python library for Lenses.io / Kafka platform engineers

Kafka De/Serializer using avro and Confluent's Schema Registry

Ansible role to install Apache Kafka

Automated Real-Time Indian Railway Twitter Complaint Administration System. It uses Apache Kafka, Spark, MySQL, PHP. The full project is deployed on A...

A plugin for the Besu enterprise-grade Ethereum client with the aim of making it easier to extract chain data into a variety of different data stores...

Scrapy and Kafka

Kafka Partitions Assignment Optimizer

基于Spring Boot 2.2.x ，后续将不断加入其他框架示例，以期能将这些功能整合起来进行项目的独立开发。后续将持续更新......

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

Web hooks for message queues

Covid19 India Patients Analyzer and Telegram Bot

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