Topic

kafka

Repositories (1207)

microservice-scaffold
microservice-scaffold jackson-zb Java

基于Spring Cloud(Greenwich.SR2)搭建的微服务脚手架(适用于在线系统),已集成注册中心(Nacos Config)、配置中心(Nacos Discovery)、认证授权(Oauth 2...

256
hsweb-iot-cloud
hsweb-iot-cloud hs-web JavaScript

本项目已迁移至 github.com/jetlinks

255
dotnet-new-caju
dotnet-new-caju ivanpaulovich C#

Learn Clean Architecture with .NET Core 3.0 :fire:

252
yivnet
yivnet yiv Go

Yivnet is a microservice game server base on go-kit

250
gosiris
gosiris teivah Go

An actor framework for Go

250
jikkou
jikkou streamthoughts Java

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

249
gimel
gimel paypal Scala

Big Data Processing Framework - Unified Data API or SQL on Any Storage

246
phpkafka
phpkafka swoole PHP

PHP Kafka client is used in PHP-FPM and Swoole. PHP Kafka client supports 50 APIs, which might be one that supports the most message types ever.

245
kafka-streams-in-action
kafka-streams-in-action bbejeck Java

Source code for the Kafka Streams in Action Book

244
dagger
dagger raystack Java

Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming...

243
kafka-health-check
kafka-health-check andreas-schroeder Go

Health Check for Kafka Brokers.

242
laravel-queue
laravel-queue php-enqueue PHP

Laravel Enqueue message queue extension. Supports AMQP, Amazon SQS, Kafka, Google PubSub, Redis, STOMP, Gearman, Beanstalk and others

240
azure-event-hubs-spark
azure-event-hubs-spark Azure Scala

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

238
kafka-connect-storage-cloud
kafka-connect-storage-cloud confluentinc Java

Kafka Connect suite of connectors for Cloud storage (Amazon S3)

237
operators
operators kudobuilder Shell

Collection of Kubernetes Operators built with KUDO.

235
recommendSys
recommendSys jasonTangxd Java

推荐项目(实时推荐和离线推荐)

234
Go-CQRS-Kafka-gRPC-Microservices
Go-CQRS-Kafka-gRPC-Microservices AleksK1NG Go

Go gRPC Kafka CQRS microservices with tracing

232
Drain3
Drain3 logpai Python

Drain log template miner in Python3

228
liiklus
liiklus bsideup Java

Reactive (RSocket/gRPC) Gateway for the event-based systems

225
debezium-ui
debezium-ui debezium TypeScript

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

224
bigdata_practice
bigdata_practice TurboWay Python

大数据分析可视化实践

224
kafka-spring-boot-example
kafka-spring-boot-example thepracticaldeveloper Java

Spring Boot application showing basic configuration to work with Kafka

222
amazonriver
amazonriver hellobike Go

amazonriver 是一个将postgresql的实时数据同步到es或kafka的服务

221
delivery_boy
delivery_boy zendesk Ruby

A simple way to publish messages to Kafka from Ruby applications

221
kcli
kcli cswank Go

A kafka command line browser

220
istio-micro
istio-micro xiaomeng79 Go

istio 微服务示例代码 grpc+protobuf+echo+websocket+mysql+redis+kafka+docker-compose

218
Thunder
Thunder Nepxion Java

⚡️ Nepxion Thunder is a distribution RPC framework based on Netty + Hessian + Kafka + ActiveMQ + Tibco + Zookeeper + Redis + Spring Web MVC + Spring...

217
kafka
kafka optiopay Go

Go driver for Kafka

216
kafka-client
kafka-client uber-go Go

Go client library for Apache Kafka

216
registry
registry hortonworks Java

Schema Registry

216
phobos
phobos phobos Ruby

Simplifying Kafka for ruby apps

216
kafka-delta-ingest
kafka-delta-ingest delta-io Rust

A highly efficient daemon for streaming data from Kafka into Delta Lake

215
java-library-examples
java-library-examples hellokaton Java

💪 example of common used libraries and frameworks, programming required, don't fork man.

214
ABRiS
ABRiS AbsaOSS Scala

Avro SerDe for Apache Spark structured APIs.

214
firecamp
firecamp cloudstax Go

Serverless Platform for the stateful services

212
kafka-connect-iot-mqtt-connector-example
kafka-connect-iot-mqtt-connector-example kaiwaehner Shell

Internet of Things Integration Example => Apache Kafka + Kafka Connect + MQTT Connector + Sensor Data

211
esupdater
esupdater WGrape PHP

A high-performance lightweight framework of PHP to achieve incremental update of ES documents / 一个基于Canal实现ES文档增量更新的高性能轻量框架

210
Asky
Asky Askyms C#

Asky开源架构:极简、轻量、极致性能《Asky零基础1小时学编程 dnc+vue+tidb+redis+rabbitMQ+ES》QQ群 779699538

209
MasterChief
MasterChief YanZhiwei C#

C# 开发辅助类库,和士官长一样身经百战且越战越勇的战争机器,能力无人能出其右。

209
bigdata-playground
bigdata-playground Chabane TypeScript

A complete example of a big data application using : Kubernetes (kops/aws), Apache Spark SQL/Streaming/MLib, Apache Flink, Scala, Python, Apache Kafka...

209
springboot-demo
springboot-demo jinhx128 Java

基于SpringBoot 2.x整合各种常用开发工具,包括但不限于Redis,MyBatisPlus,RocketMQ,RabbitMQ,Elasticsearch,Quartz,Xxl-Job,Kafka等。

209
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...

207
waterdrop
waterdrop karafka Ruby

Standalone Karafka library for producing Kafka messages

207
data_engineer_career
data_engineer_career dhkdn9192 Jupyter Notebook

DE직무에 필요한 모든 것

207
sangrenel
sangrenel jamiealquiza Go

Apache Kafka load testing "...basically a cloth bag filled with small jagged pieces of scrap iron"

204
goharvest
goharvest obsidiandynamics Go

Transactional outbox harvester for Postgres → Kafka, written in Go

202
kafka-view
kafka-view fede1024 Rust

Kafka web UI

201
azure-event-hubs-for-kafka
azure-event-hubs-for-kafka Azure Java

Azure Event Hubs for Apache Kafka Ecosystems

200
srclient
srclient riferrei Go

Golang Client for Schema Registry

200
remora
remora zalando-incubator Scala

Kafka consumer lag-checking application for monitoring, written in Scala and Akka HTTP; a wrap around the Kafka consumer group command. Integrations w...

199