Topic

kafka

Repositories (1422)

debezium-ui
debezium-ui debezium TypeScript

ARCHIVED: A web UI for Debezium; Please log issues at https://issues.redhat.com/browse/DBZ.

352
scala-kafka-client
scala-kafka-client cakesolutions Scala

Scala helper modules for operating the Apache Kafka client library (0.9.x - 2.1.0)

350
kafka-connect-file-pulse
kafka-connect-file-pulse streamthoughts Java

🔗 A multipurpose Kafka Connect connector that makes it easy to parse, transform and stream any file, in any format, into Apache Kafka

350
Gather-Deployment
Gather-Deployment huseinzol05 Jupyter Notebook

Gathers Python deployment, infrastructure and practices.

348
fw-spring-cloud
fw-spring-cloud xuyisu Java

SpringCloud构建实战、从入门到高级,包含eureka、zuul、gateway、feign、ribbon、hystrix、mq、turbine、nacos、elk、consul、zookeeper、rocketmq、kafka、分...

347
springwolf-core
springwolf-core springwolf Java

Automated documentation for event-driven applications built with Spring Boot

347
mqttx
mqttx Amazingwujun Java

MQTTX Project 完整实现 mqttv3.1.1 协议,旨在提供易于使用且性能优异的 mqtt broker

344
firehose
firehose raystack Java

Firehose is an extensible, no-code, and cloud-native service to load real-time streaming data from Kafka to data stores, data lakes, and analytical st...

343
clickhouse-sink-connector
clickhouse-sink-connector Altinity Python

Replicate data from MySQL, Postgres and MongoDB to ClickHouse®

343
kmq
kmq softwaremill Scala

Kafka-based message queue

341
kafka-gitops
kafka-gitops devshawn Java

🚀Manage Apache Kafka topics and generate ACLs through a desired state file.

341
stream
stream wendy512 Java

Stream supports lightweight messaging within Spring-based applications and supports integration with external systems through declarative adapters

339
transaction-outbox
transaction-outbox gruelbox Java

Reliable eventual consistency for Microservices

339
trubka
trubka xitonix Go

A CLI tool for Kafka

337
strimzi-kafka-bridge
strimzi-kafka-bridge strimzi Java

An HTTP bridge for Apache Kafka®

337
yozefu
yozefu MAIF Rust

An interactive terminal user interface (TUI) application for exploring data of a kafka cluster.

335
Pos
Pos NHadi JavaScript

Sample Application DDD, Reactive Microservices, CQRS Event Sourcing Powered by DERMAYON LIBRARY

330
wirbelsturm
wirbelsturm miguno Shell

[PROJECT IS NO LONGER MAINTAINED] Wirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big...

329
GameServer4j
GameServer4j jzyong Java

Distributed Java game server, including login, gateway, game demo

329
blog
blog hhstore

My Tech Blog: about Mojo / Rust / Golang / Python / Kotlin / Flutter / VueJS / Blockchain etc.

329
every-single-day-i-tldr
every-single-day-i-tldr sderosiaux

A daily digest of the articles or videos I've found interesting, that I want to share with you.

327
distributed_framework
distributed_framework ydf0509 Python

pip install function_scheduling_distributed_framework,python通用分布式函数调度框架。python万能超高并发神器,改成funboost框架名字,停止更新,只更新fun...

327
digital-restaurant
digital-restaurant idugalic Kotlin

DDD. Event sourcing. CQRS. REST. Modular. Microservices. Kotlin. Spring. Axon platform. Apache Kafka. RabbitMQ

321
de-zoomcamp-ui
de-zoomcamp-ui Hamagistral Python

🎨 UI for the Free Data Engineering Zoomcamp Course provided by DataTalksClub

320
ksql
ksql confluentinc Java

The database purpose-built for stream processing applications.

314
kafkastreams-cep
kafkastreams-cep fhussonnois Java

Complex Event Processing on top of Kafka Streams

314
100xDevs_2.0
100xDevs_2.0 vishalsingh2972 TypeScript

List of all the imp concepts and assignments covered during 100xDevs 2.0

313
data-accelerator
data-accelerator microsoft C#

Data Accelerator for Apache Spark simplifies onboarding to Streaming of Big Data. It offers a rich, easy to use experience to help with creation, edit...

312
intents-operator
intents-operator otterize Go

Manage network policies, AWS, GCP & Azure IAM policies, Istio Authorization Policies, and Kafka ACLs in a Kubernetes cluster with ease.

312
ecommerce-microservice-backend-app
ecommerce-microservice-backend-app SelimHorri Java

Spring Boot microservices app with Spring Cloud, Robust and resilient backend managing e-Commerce app

312
video-stream-analytics
video-stream-analytics baghelamit Java
311
stove
stove Trendyol Kotlin

Stove: The easiest way of writing e2e/component tests for your JVM back-end app with Kotlin

309
kafka-cheat-sheet
kafka-cheat-sheet lensesio

Curated by Lenses.io

308
fluent-plugin-kafka
fluent-plugin-kafka fluent Ruby

Kafka input and output plugin for Fluentd

307
ksql-udf-deep-learning-mqtt-iot
ksql-udf-deep-learning-mqtt-iot kaiwaehner Java

Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data

307
cqrs-manager-for-distributed-reactive-services
cqrs-manager-for-distributed-reactive-services capitalone Java

Experimental CQRS and Event Sourcing service

303
Wow
Wow Ahoo-Wang Kotlin

Modern Reactive CQRS Architecture Microservice development framework based on DDD and EventSourcing | 基于 DDD & EventSourcing 的现代响应式 CQRS 架构...

303
jikkou
jikkou streamthoughts Java

The Open source Resource as Code framework for Apache Kafka. Jikkou helps you implement GitOps for Kafka at scale!

303
kroxylicious
kroxylicious kroxylicious Java

Kroxylicious, the snappy open source proxy for Apache Kafka®

301
confluent-kafka-javascript
confluent-kafka-javascript confluentinc JavaScript

Confluent's Apache Kafka JavaScript client

299
camel-quarkus
camel-quarkus apache Java

Apache Camel Quarkus

299
parallel-consumer
parallel-consumer confluentinc Java

Parallel Apache Kafka client wrapper with per message ACK, client side queueing, a simpler consumer/producer API with key concurrency and extendable n...

297
awesome-docker-compose
awesome-docker-compose ruanbekker Makefile

My Collection of Docker Compose Files. Use "make up" to test it.

297
scalatest-embedded-kafka
scalatest-embedded-kafka manub Scala

A library that provides an in-memory Kafka instance to run your tests against.

295
kafka-operator
kafka-operator krallistic Go

A Kafka Operator for Kubernetes

293
zoe
zoe adevinta Kotlin

The Kafka CLI for humans

293
kouncil
kouncil Consdata TypeScript

Powerful dashboard for your Kafka. Monitor status, manage groups, topics, send messages and diagnose problems. All in one user friendly web dashboard.

293
Hummingbird
Hummingbird guoming C#

分布式锁,分布式ID,分布式消息队列、配置中心、注册中心、服务注册发现、超时、重试、熔断、负载均衡

292
qbusbridge
qbusbridge Qihoo360 C++

The Apache Kafka Client SDK

290
node-sinek
node-sinek nodefluent TypeScript

:tophat: (legacy) high level Node.js Kafka client

289