Topic

kafka

Repositories (1422)

camel-kafka
camel-kafka ipolyzos Java

Apache Camel, Kafka Component

21
kpax
kpax h12w Go

A modular & idiomatic Kafka client in Go

21
WorkflowGs
WorkflowGs hedes-gs Java

Archive and manage your Sony RAW images

21
kafka_data_viewer
kafka_data_viewer alshpak Scala

Tool that providing ability to access kafka data - query items in topics and kafka metadata

21
dockerize-and-ansible
dockerize-and-ansible cobolbaby HTML

:whale: Build & Deploy the containerized Dev & Prod Env

21
edge-fuse
edge-fuse Nexenta C

Edge-X S3 API, mount S3 bucket for full POSIX read/write access

21
franzy
franzy clj-kafka Clojure

A set of Clojure libraries to work with Apache Kafka (producer, consumer, rebalancing, administration, and validation).

21
kafka_producer_consumer_tutorial
kafka_producer_consumer_tutorial firebase007 JavaScript

A tutorial on building a real-time data streaming application pipeline with Apache Kafka🔥🔥🔥

21
fastdata-cluster
fastdata-cluster markush81 Jinja

Fast Data Cluster (Apache Cassandra, Kafka, Spark, Flink, YARN and HDFS with Vagrant and VirtualBox)

21
bigdata-service
bigdata-service windwant Java

hadoop flume hbase kafka storm；读取kafka数据=》storm实时处理（分割字符，统计字符）=》写入hdfs

21
bandar-log
bandar-log yahoo Scala

Monitoring tool to measure flow throughput of data sources and processing components that are part of Data Ingestion and ETL pipelines.

21
kafka-application4s
kafka-application4s DivLoic Scala
21
JavaNotes
JavaNotes OrangeDrk

Java后端学习笔记。包括Linux、maven、git、互联网架构、大数据体系等

21
spring-reactive-kafka-sse
spring-reactive-kafka-sse renatoaguimaraes Java

Stream with Spring Boot Reactive + Kafka + Server Sent Event + Cassandra.

21
vault-plugin-secrets-kafka
vault-plugin-secrets-kafka Mongey Go

A vault plugin for generating ACLs for dynamic users

21
kafka-do
kafka-do wopehq Go

Higher level abstraction for franz-go.

21
Koic
Koic PoCInnovation Python

Connected scarecrow for smart predator repulsion.

21
strimzi.github.io
strimzi.github.io strimzi HTML

Strimzi web site project

21
console
console GigahexHQ TypeScript

Open source data infrastructure platform. Designed for developers, built for speed.

21
ksql_workshop
ksql_workshop aweagel Dockerfile

Let's Learn ksqlDB

21
airflow-event-plugins
airflow-event-plugins shlin168 Python

event-triggered plugins for airflow

21
fullbazel
fullbazel drakery3d TypeScript

Fullstack Example Monorepo with Bazel 🌿

21
activator-reactive-kafka-scala
activator-reactive-kafka-scala softwaremill Scala

Activator template for Reactive Kafka

20
lenses-jdbc
lenses-jdbc lensesio Kotlin

Lenses.io JDBC driver for Apache Kafka

20
infinity
infinity mgubaidullin Java

Prototype of forecast service that uses machine learning to deliver forecasts

20
kafka-connect-marklogic
kafka-connect-marklogic sanjuthomas Java

Kafka Sink Connect MarkLogic

20
kafka-mirror-tester
kafka-mirror-tester AppsFlyer Go

A tool to test the performance and correctness of kafka mirroring.

20
spring-boot-learn-box
spring-boot-learn-box zhaoyunxing92 CSS

spring boot集成其他组件

20
rewind
rewind xtaci Go

Text-Based UI for Kafka

20
Storm-Kafka
Storm-Kafka Will-Grindelwald Java

Storm Kafka 流数据 处理系统

20
Perfect-Kafka
Perfect-Kafka PerfectlySoft Swift

An Express Swift Client of Apache Kafka 0.8, the Stream Processing Platform

20
aidp
aidp weiboad C++

weiboAd Infrastructure Data Processor : kafka consumer embedded Lua scripting language in data process framework

20
http-kafka-gateway
http-kafka-gateway 137-rick Java

an gateway for kafka by http

20
hdinsight-kafka-tools
hdinsight-kafka-tools hdinsight Python

HDInsight Kafka Tools

20
konsumerator
konsumerator lwolf Go

Kafka Consumer Operator. Kubernetes operator to manage consumers of unbalanced kafka topics with per-partition vertical autoscaling based on Prometheu...

20
lambda-architecture-demo
lambda-architecture-demo dorianbg Jupyter Notebook

Developing a Lambda Architecture pipeline using Apache Kafka, Spark Structured Streaming, Redshift, S3, Python

20
Rabbit-OJ-Backend
Rabbit-OJ-Backend Rabbit-OJ Go

Using Go & MySQL & Docker & Web Socket & gRPC & Kafka & Zookeeper & Protobuf. Distributed and Scalable Open Judge System for Algorithms.

20
T-Watch
T-Watch sherlockjjj Jupyter Notebook

Real Time Twitter Sentiment Analysis Product

20
kafka-cli
kafka-cli shafreeck Go

A command line client of kafka

20
HumanResources
HumanResources mertcakmak2 Java

Account Registration and Confirmation. Exception Handling. Caching with Redis.Mail sender by Apache Kafka.Notification send with RabbitMq.

19
message_middleware
message_middleware 1046102779 Go

为了促进产品的平台化建设, 把kafka消息队列从服务中抽象出来。让消息队列只关注消息的订阅和发布，使用微服务，减少与业务逻辑的耦合, 该服务支持多实例部署

19
vkitm
vkitm mmolimar Scala

A native Kafka protocol proxy for Apache Kafka

19
kafka-phplayground
kafka-phplayground leocavalcante PHP

🎸 Just some fun with Kafka, PHP and Swoole

19
kubernetes-kafka
kubernetes-kafka nbogojevic Shell

Managing kafka clusters in Kubernetes and OpenShift

19
triton
triton tal-tech Go

Triton is a high-performance mq consumer, support kafka,rabbit-mq,rocketmq,nsq and other mq

19
Tweet-Analysis-With-Kafka-and-Spark
Tweet-Analysis-With-Kafka-and-Spark harshkavdikar1 Python

A real time analytics dashboard to analyze the trending hashtags and @ mentions at any location using kafka and spark streaming.

19
kanadi
kanadi zalando-nakadi Scala

Kanadi is a Nakadi client for Scala

19
spring-kafka-samples
spring-kafka-samples schroedermatt Groovy

Kafka Listener sample repository

19
chronos-pipeline
chronos-pipeline chronos-project JavaScript

A data pipeline for processing event data

19
felice
felice heetch Go

Felice is a nascent, opinionated Kafka library for Go, in Go

18