kafka

Distributed crawling/scraping, Kafka And Redis based components for Scrapy

Kubernetes Kafka Overview, Burrow consumer lag stats, Kafka disk usage

Inspr is an agnostic application mesh for simpler, faster, and securer development of distributed applications (dApps).

大数据学习，主要涉及Kafka、ZooKeeper、Hive、HBase、Spark

Common Lisp library for Kafka

Standalone alternatives to Kafka Connect Connectors

Extensible streaming ingestion pipeline on top of Apache Spark

This project uses Apache Flink as a stream engine that consumes data from the File system or Kafka brokers and exposes metrics using Prometheus and Gr...

IoT Transportation demo using Red Hat OpenShift and Middleware technologies

Vostok Hercules is an open-source distributed system based on Apache Kafka and used for reliable delivery of telemetry data from microservices to stor...

☝️ go-graphql subscription over Kafka/Redis/NSQ example

Provides consistent standard use of common components of the .Net Core language

Open source, accessibility driven web application for monitoring and alerting Apache Kafka broker metrics

SNMP Trap to JSON Forwarder

EasyKafka is a Kafka/Redpanda client sub-system for unreal engine. It supports producing and consuming records through blueprint and C++.

An umbrella project for multiple implementations of model serving

EMQX plugin Kafka bridge send messgaes from broker to kafka

kafka connector 插件，支持输入 mysql binlog 和 json 格式写入ClickHouse。持续更新

Scala wrapper for kafka consumer and producer

基于SSM + Spring Boot + Thymeleaf开发的论坛社区网站

This project provides and example of end to end data processing application created using the combination of Amazon Managed Streaming for Apache Kafka...

Generate Apache Avro schemas for Python types including standard library data-classes and Pydantic data models.

Kotlin Clean Architecture and CQRS microservice

The one-stop shop Docker Desktop Extension for seamless Kafka cluster monitoring and troubleshooting 🐋 🚀

Simple desktop application for Apache Kafka

Databricks. Incremental data processing, task orchestration, and production job monitoring.

Redis Kafka Connector (Source and Sink) by Redis

Flask Kafka consumer full implementation example. Ideal for a microservices architecture.

基于nest的推送系统（集成kafka消息， redis任务队列），可实现对邮箱 手机号 websocket app客户端的消息推送

springboot大杂烩

oracle to kafka cdc tools, Synchronize Oracle online redo log to kafka or other big data platforms in realtime

Apache Kafka Docker image using Kafka Raft metadata mode (KRaft). https://hub.docker.com/r/moeenz/docker-kafka-kraft

Big Data webapp using Chicago street congestion, crashes, red light violations, and speed camera violations

A chat server based on the microservice architecture to ensure high availability, high throughput, horizontal scalability

2021年超全超详细的最新大数据开发面试题，附答案解析，大数据面试题，看这一套就够了

Streaming Synthetic Sales Data Generator: Streaming sales data generator for Apache Kafka, written in Python

Crossplane provider for Kafka

Apache Flink Demo Projects

This project serves as a comprehensive guide to building an end-to-end data engineering pipeline using TCP/IP Socket, Apache Spark, OpenAI LLM, Kafka...

This repo contains Big Data Project, its about "Real Time Twitter Sentiment Analysis via Kafka, Spark Streaming, MongoDB and Django Dashboard".

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

SpringBoot商城系统Demo，主要功能：提供了商城系统的后端Api，不包含前端页面，体现了前后端解耦分离的思想。实现了商品，购物车，订单系统，单点登录系统等4个...

Kafka Streams in Clojure

Perl implementation of Kafka API (official CPAN module)

Jenkins Remoting over Apache Kafka

A message handler implementation for MirrorMaker to change the target topic name during mirroring.

Kafka Connect Examples

Motor.NET is a microservice framework based on Microsoft.Extensions.Hosting

An open-source visualization tool for monitoring Kafka cluster metrics

Analyzing a network of tweets and retweets using graph algorithms