kafka
Repositories (1408)
💪 example of common used libraries and frameworks, programming required, don't fork man.
Serverless Platform for the stateful services
Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data
A collection of kafka-resources
k6 extension to load test Apache Kafka with support for various serialization formats, SASL, TLS, compression, Schema Registry client and beyond
Go driver for Kafka
Spring Boot Microservices project (Gateway, Config Server, Kafka)
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...
A high-performance lightweight framework of PHP to achieve incremental update of ES documents / 一个基于Canal实现ES文档增量更新的高性能轻量框架
基于SpringBoot 2.x整合各种常用开发工具，包括但不限于Redis，MyBatisPlus，RocketMQ，RabbitMQ，Elasticsearch，Quartz，Xxl-Job，Kafka等。
A complete example of a big data application using : Kubernetes (kops/aws), Apache Spark SQL/Streaming/MLib, Apache Flink, Scala, Python, Apache Kafka...
Serverless multi-protocol + multi-destination event collection system.
C# 开发辅助类库，和士官长一样身经百战且越战越勇的战争机器，能力无人能出其右。
Mirus is a cross data-center data replication tool for Apache Kafka
Everything about Apache Kafka
Asky开源架构：极简、轻量、极致性能《Asky零基础1小时学编程 dnc+vue+tidb+redis+rabbitMQ+ES》QQ群 779699538
Transactional outbox harvester for Postgres → Kafka, written in Go
DE직무에 필요한 모든 것
Kafka-ML: connecting the data stream with ML/AI frameworks (now TensorFlow and PyTorch!)
Apache Kafka load testing "...basically a cloth bag filled with small jagged pieces of scrap iron"
NestJS CQRS module for EventStore.org. It requires @nestjs/cqrs
Kafka consumer lag-checking application for monitoring, written in Scala and Akka HTTP; a wrap around the Kafka consumer group command. Integrations w...
ClickHouse Kafka Connector
A prototype project of big data platform, the source codes of the book Big Data Platform Architecture and Prototype
Self-contained examples of Apache Spark streaming integrated with Apache Kafka.
Learn the Confluent Schema Registry & REST Proxy
Klaw, the latest OS tool by Aiven, helps enterprises cope with Apache Kafka(r) topics, schema registry and connectors governance by introducing roles/...
An Hexagonal Architecture with DDD + Aggregates + Event Sourcing using .NET Core, Kafka e MongoDB (Blog Engine)
GraphQL Rust Demo.
《Kafka技术内幕》代码
[Java工程师必备+学习+知识点+面试]：包含计算机网络知识、JavaSE、JVM、Spring、Springboot、SpringCloud、Mybatis、多线程并发、netty、MySQL、MongoDB、Elast...
A set of tools and examples to run a flow-pipeline (sFlow, NetFlow)
.NET event stream projection and scheduling platform with CosmosDB, DynamoDB, EventStoreDB, MemoryStore, message-db, Equinox and Kafka integrations
Thin Scala wrapper around Kafka Streams Java API
A hybrid Big Data pipeline architecture that combines a real-time streaming layer with a batch layer to process large datasets(Lambda Architecture)
🚀 Azkarra is a lightweight java framework to make it easy to develop, deploy and manage cloud-native streaming microservices based on Apache Kafka St...
Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
Spark Structured Streaming / Kafka / Cassandra / Elastic
Apollo graphql subscriptions over Kafka protocol
Apache flink
Go products microservice
springboot和dubbo、netty的集成，spring-ai-*的集成，redis mongodb的nosql模板， kafka rocketmq rabbit的MQ模板， solr solrcloud elasticsearch查询引擎
An online code compiler supporting 11 programming languages (Java, Kotlin, Scala, C, C++, C#, Golang, Python, Ruby, Rust and Haskell) for competitive...
Open Source Cloud Native Ingestion engine
基于Go语言gin框架搭建的可快速开发的微服务脚手架
Sample application for Lightning Web Components and Salesforce Platform runtime and compute capabilities. Part of the sample gallery. Electric car man...
:boom: :rocket: 封装sparkstreaming动态调节batch time(有数据就执行计算)；:rocket: 支持运行过程中增删topic；:rocket: 封装sparkstreaming 1.6 - kafka 0...
DDD应用框架
Neo4j Kafka Connector
[https://www.sofineday.com], golang项目开发脚手架,集成最佳实践(gin+gorm+go-redis+mongo+cors+jwt+json日志库zap(支持日志收集到kafka或mongo)+消息队列kafk...