kafka

Self-contained examples of Apache Spark streaming integrated with Apache Kafka.

A prototype project of big data platform, the source codes of the book Big Data Platform Architecture and Prototype

Kafka-ML: connecting the data stream with ML/AI frameworks (now TensorFlow and PyTorch!)

《Kafka技术内幕》代码

Mirus is a cross data-center data replication tool for Apache Kafka

A Broadway connector for Kafka

Silverback is a simple but feature-rich message bus for .NET core (it currently supports Kafka, RabbitMQ and MQTT).

Confluent's Apache Kafka .NET client

SmallRye Reactive Messaging

Everything about Apache Kafka

Thin Scala wrapper around Kafka Streams Java API

Learn the Confluent Schema Registry & REST Proxy

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

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

Apollo graphql subscriptions over Kafka protocol

:boom: :rocket: 封装sparkstreaming动态调节batch time(有数据就执行计算)；:rocket: 支持运行过程中增删topic；:rocket: 封装sparkstreaming 1.6 - kafka 0...

Quix Streams - A library for telemetry data streaming. Python Stream Processing

[https://www.sofineday.com], golang项目开发脚手架,集成最佳实践(gin+gorm+go-redis+mongo+cors+jwt+json日志库zap(支持日志收集到kafka或mongo)+消息队列kafk...

springboot和dubbo、netty的集成，spring-ai-*的集成，redis mongodb的nosql模板， kafka rocketmq rabbit的MQ模板， solr solrcloud elasticsearch查询引擎

[Java工程师必备+学习+知识点+面试]：包含计算机网络知识、JavaSE、JVM、Spring、Springboot、SpringCloud、Mybatis、多线程并发、netty、MySQL、MongoDB、Elast...

DDD应用框架

Spark Structured Streaming / Kafka / Cassandra / Elastic

程序员 学习资料，以及一些书籍电子书，如果对您有所帮助，还希望大家多多star，更多资料请关注《Java有货》微信公众号获取

Go products microservice

Write your Spark data to Kafka seamlessly

🚀 Azkarra is a lightweight java framework to make it easy to develop, deploy and manage cloud-native streaming microservices based on Apache Kafka St...

我,请始皇[打钱]是一个前后端分离的工具人系统，项目采用 SpringBoot+Go+Vue 开发，项目加入常见的企业级应用所涉及到的技术点，例如 Redis、RabbitMQ 等(主要是...

An online code compiler supporting 11 programming languages (Java, Kotlin, Scala, C, C++, C#, Golang, Python, Ruby, Rust and Haskell) for competitive...

light, fast, scalable, streaming microservices made easy

本人的RabbitMQ和Kafka详细笔记以及示例代码

NestJS CQRS module for EventStore.org. It requires @nestjs/cqrs

KLoadGen is kafka load generator plugin for jmeter designed to work with AVRO, JSON and PROTOL-BUFFERS schema Registries.

A search framework and multi-tenant search platform based on java, kafka, kafka connect, elasticsearch

js extensions for the open-telemetry project

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

PG数据同步工具（Java实现）

Your one stop shop to do anything with Kafka. Producing, consuming, transacting, administrating; 0.8.0 through 3.2+

all kinds of scrapy demo

A collection of kafka-resources

The source code of the book "Microservices Patterns (Chris Richardson)" and the personal study note of Eventuate Tram Framework (The whole solution...

GraphQL Rust Demo

Extended datasource support for Spark/Hadoop on Aliyun E-MapReduce.

Sample application for Lightning Web Components and Salesforce Platform runtime and compute capabilities. Part of the sample gallery. Electric car man...

Kafka ecosystem ... but step by step!

This library wraps Kafka's embedded test cluster, allowing you to more easily create and run integration tests using JUnit against a "real" kafka serv...

Kafka 한국 사용자 모임에서 운영하는 meetup repository

Raccoon is a high-throughput, low-latency service to collect events in real-time from your web, mobile apps, and services using multiple network proto...

StreamLine - Streaming Analytics

Neo4j Kafka Integrations, Docs =>