Topic

kafka

Repositories (1443)

agent-py
agent-py kkjiangk Python

Personal AIOps engineering project with durable workflows, scoped hybrid retrieval, reliable event delivery, and verified API/browser contracts.

71
kafka-streams-query
kafka-streams-query lightbend Scala

Library offering http based query on top of Kafka Streams Interactive Queries

70
kafka-helm-charts
kafka-helm-charts lensesio Smarty

In-deprecation. For Lenses please check lensesio/lenses-helm-charts. Soon Stream Reactor will also get its own Helm repository.

70
syncer
syncer zzt93 Java

Sync & Manipulate data from MySQL/MongoDB to Elasticsearch/MySQL/Kafka Endpoint

70
gcs-connector-for-apache-kafka
gcs-connector-for-apache-kafka Aiven-Open Java

Aiven's GCS Sink Connector for Apache Kafka®

70
FlinkTutorial
FlinkTutorial lei-zuquan Java

FlinkTutorial 专注大数据Flink流试处理技术。从基础入门、概念、原理、实战、性能调优、源码解析等内容,使用Java开发,同时含有Scala部分核心代码。欢迎关注我...

70
ksqldb-go
ksqldb-go rmoff Go

A Golang client for ksqlDB

70
go-dcp-kafka
go-dcp-kafka Trendyol Go

The Go implementation of the Couchbase to Kafka with DCP.

70
zkafka
zkafka zillow Go

An efficient and scalable library for stateless Kafka message processing written in Go

70
springboot-kafka-websocket
springboot-kafka-websocket ivangfr Java

The goal of this project is to implement two Spring Boot applications: bitcoin-api and bitcoin-client. The bitcoin-api application simulates BTC price...

70
streamhouse
streamhouse gbram1 Rust

Open-source event streaming platform built on S3. Kafka-compatible APIs, built-in SQL engine, schema registry — one Rust binary replaces Kafka + Zoo...

70
kafka-kubernetes
kafka-kubernetes ramhiser

Apache Kafka on Kubernetes

69
model-serving-tutorial
model-serving-tutorial lightbend Scala

Code and presentation for Strata Model Serving tutorial

69
Dermayon
Dermayon NHadi C#

Dermayon is Library for supporting build large application,distributed application, scalable, microservices, cqrs, event sourcing, including generic e...

69
SpringBoot
SpringBoot intomylife Java

SpringBoot 整合各类框架和应用

69
SkaETL
SkaETL skalogs Java

Open Source ETL designed for and dedicated to Log processing and transformation

69
pybigdata
pybigdata TurboWay Python

使用 python 操作大数据的各种组件

69
camel-kafka-connector-examples
camel-kafka-connector-examples apache Java

Apache Camel Kafka Connector Examples

69
avro_ex
avro_ex beam-community Elixir

An Avro Library that emphasizes testability and ease of use.

69
ksqlSuite
ksqlSuite oslabs-beta JavaScript

Node.js client for ksqlDB

69
shield
shield gy-games

基于Strom的日志实时流量分析主动防御(CCFirewall)系统

68
faust-docker-compose-example
faust-docker-compose-example marcosschroh Python

Faust dockerized application

68
OPC-DA
OPC-DA SetGeek Java

基于utgard的OPC DA客户端

68
kafka-crypto-questdb
kafka-crypto-questdb Yitaek Python

Using Kafka to track cryptocurrency price trends

68
kafka-connect-msk-demo
kafka-connect-msk-demo garystafford Python

For a series of posts on Amazon MSK, Amazon EKS, and Amazon EMR

68
bufstream-demo
bufstream-demo bufbuild Go

A demo of Bufstream, a drop-in replacement for Apache Kafka that's 8x less expensive to operate and brings broker-side schema awareness to Kafka

68
kandalf
kandalf hellofresh Go

RabbitMQ to Kafka bridge

67
ansible-kafka
ansible-kafka jaytaylor

Ansible Kafka role

67
pg2kafka
pg2kafka blendle Go

Ship changes in Postgres 🐘 to Kafka 📖

67
gatling-kafka
gatling-kafka mnogu Scala

A Gatling stress test plugin for Apache Kafka protocol

67
ansible-playbook
ansible-playbook InsightDataScience Python

Ansible playbook to deploy distributed technologies

67
sidekiq-backend
sidekiq-backend karafka Ruby

[Unmaintained] Karafka Sidekiq backend for background messages processing

67
ccloud-tools
ccloud-tools confluentinc HCL

Running Tools from Confluent Platform along with your Confluent Cloud™ Cluster

67
docker-kafka-alpine
docker-kafka-alpine blacktop Shell

Alpine Linux based Kafka Docker Image

67
data-engineering-interviews
data-engineering-interviews kislerdm Python

Data engineering interviews Q&A for data community by data community

67
franzView
franzView oslabs-beta TypeScript

An open source kafka monitoring and management tool built with Javascript developers in mind!

67
kafka-large-message-serde
kafka-large-message-serde bakdata Java

A Kafka Serde that reads and writes records from and to Blob storage (S3, Azure, Google) transparently.

67
bigdata-tutorial
bigdata-tutorial dunwu Java
67
clean-hexagonal-architecture-kafka-saga-outbox
clean-hexagonal-architecture-kafka-saga-outbox alicanli1995 Java

Food Ordering Project with Clean and Hexagonal Architecture With Kafka Messaging System And Outbox Table

67
kattlo-cli
kattlo-cli kattlo Java

Kattlo CLI Project

66
ssm
ssm wangxiaoxian JavaScript

销售系统项目,spring+spring mvc+mybatis+dubbo+kafka+redis+maven

66
kafka-protobuf-serde
kafka-protobuf-serde daniel-shuy Java

Serializer/Deserializer for Kafka to serialize/deserialize Protocol Buffers messages

66
pact-example
pact-example christian-draeger Kotlin

Example project to demonstrate Contract Testing via Pact.

66
nginx-kafka-log-module
nginx-kafka-log-module kaltura C

Send Kafka messages from Nginx

66
TrafficTeach
TrafficTeach leelovejava Java

大数据项目:车流量监控

66
quarkus-microservices-poc
quarkus-microservices-poc MossabTN Java

Very simplified shop sales system made in a microservices architecture using quarkus

66
Data-pipeline-project
Data-pipeline-project hiejulia Jupyter Notebook

Data pipeline project

66
streamops
streamops io-streamops JavaScript

Kafka and Red Panda Streaming Operations Platform

66
order-and-gift-project
order-and-gift-project sinkyoungdeok Kotlin

지금까지 배웠던 기술들을 다듬을겸 주문&선물 프로젝트를 진행합니다

66
code-examples
code-examples rubykv Java

code-examples is a collection of Java/Spring based software projects implemented as POCs (Proof Of Concept)

66