karafka/karafka

Ruby and Rails efficient Kafka processing framework

Language: Ruby - Size: 6.59 MB - Last synced at: about 8 hours ago - Pushed at: about 9 hours ago - Stars: 2,169 - Forks: 186

kafbat/kafka-ui

Open-Source Web UI for managing Apache Kafka clusters

Language: Java - Size: 35 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 1,195 - Forks: 150

fede1024/rust-rdkafka

A fully asynchronous, futures-based Kafka client library for Rust based on librdkafka

Language: Rust - Size: 14.4 MB - Last synced at: 1 day ago - Pushed at: 5 days ago - Stars: 1,794 - Forks: 307

3axap4eHko/kafka-console

CLI kafka client

Language: TypeScript - Size: 11.1 MB - Last synced at: 2 days ago - Pushed at: 3 days ago - Stars: 4 - Forks: 2

floydspace/effect-kafka

📨 Effectful Kafka

Language: TypeScript - Size: 364 KB - Last synced at: about 11 hours ago - Pushed at: 23 days ago - Stars: 16 - Forks: 2

IBM/sarama

Sarama is a Go library for Apache Kafka.

Language: Go - Size: 10.1 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 12,058 - Forks: 1,816

aio-libs/aiokafka

asyncio client for kafka

Language: Python - Size: 3.2 MB - Last synced at: 1 day ago - Pushed at: 3 months ago - Stars: 1,270 - Forks: 247

strimzi/strimzi-kafka-bridge

An HTTP bridge for Apache Kafka®

Language: Java - Size: 2.61 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 307 - Forks: 125

segmentio/kafka-go

Kafka library in Go

Language: Go - Size: 1.92 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 8,084 - Forks: 813

confluentinc/confluent-kafka-javascript

Confluent's Apache Kafka JavaScript client

Language: JavaScript - Size: 5.51 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 185 - Forks: 18

confluentinc/confluent-kafka-go

Confluent's Apache Kafka Golang client

Language: HTML - Size: 506 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 4,910 - Forks: 688

jonas-grgt/ktea

Kafka TUI client

Language: Go - Size: 1.28 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 27 - Forks: 2

tulios/kafkajs

A modern Apache Kafka client for node.js

Language: JavaScript - Size: 11.3 MB - Last synced at: 7 days ago - Pushed at: 11 months ago - Stars: 3,886 - Forks: 559

twmb/franz-go

franz-go contains a feature complete, pure Go library for interacting with Kafka from 0.8.0 through 4.0+. Producing, consuming, transacting, administrating, etc.

Language: Go - Size: 4.07 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 2,261 - Forks: 229

confluentinc/confluent-kafka-python

Confluent's Kafka Python Client

Language: Python - Size: 14.3 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 290 - Forks: 917

dropwizard/dropwizard-kafka

A convenience library for Apache Kafka integration in a Dropwizard service.

Language: Java - Size: 529 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 21 - Forks: 12

confluentinc/confluent-kafka-dotnet

Confluent's Apache Kafka .NET client

Language: C# - Size: 6.32 MB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 175 - Forks: 880

arnaud-lb/php-rdkafka

Production-ready, stable Kafka client for PHP

Language: C - Size: 1020 KB - Last synced at: 10 days ago - Pushed at: about 1 month ago - Stars: 2,153 - Forks: 269

apache/pekko-connectors-kafka

Apache Pekko Kafka Connector - Pekko-Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.

Language: Scala - Size: 3.33 MB - Last synced at: 9 days ago - Pushed at: 14 days ago - Stars: 26 - Forks: 13

Farfetch/kafkaflow

Apache Kafka .NET Framework to create applications simple to use and extend.

Language: C# - Size: 24.4 MB - Last synced at: 11 days ago - Pushed at: 19 days ago - Stars: 734 - Forks: 128

zendesk/ruby-kafka

A Ruby client library for Apache Kafka

Language: Ruby - Size: 2.06 MB - Last synced at: 4 days ago - Pushed at: 28 days ago - Stars: 1,275 - Forks: 338

akka/alpakka-kafka

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

Language: Scala - Size: 4.55 MB - Last synced at: 21 days ago - Pushed at: 21 days ago - Stars: 1,414 - Forks: 384

fd4s/fs2-kafka

Functional Kafka Streams for Scala

Language: Scala - Size: 11.8 MB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 298 - Forks: 105

FundingCircle/jackdaw

A Clojure library for the Apache Kafka distributed streaming platform.

Language: Clojure - Size: 1.83 MB - Last synced at: 7 days ago - Pushed at: 11 months ago - Stars: 374 - Forks: 78

ffernandolima/confluent-kafka-core-dotnet

🚀 Kafka Core empowers developers to effortlessly build robust .NET applications on top of Confluent Kafka, focusing on simplicity, maintainability, and extensibility. With intuitive abstractions and builders, it introduces powerful features that enhance functionality and extend the official library's capabilities.

Language: C# - Size: 788 KB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 23 - Forks: 0

tillkuhn/rubin

💿 rubin - a simple record producer for Kafka topics written in Go that acts as a thin wrapper around Confluent's REST Proxy API (v3)

Language: Go - Size: 360 KB - Last synced at: 27 days ago - Pushed at: 28 days ago - Stars: 1 - Forks: 0

Bogdanp/Franz

A desktop client for Apache Kafka.

Language: Racket - Size: 9.98 MB - Last synced at: 29 days ago - Pushed at: about 1 month ago - Stars: 143 - Forks: 2

BSVN/Commons

Commons library

Language: C# - Size: 5.31 MB - Last synced at: 30 days ago - Pushed at: about 1 month ago - Stars: 7 - Forks: 9

hifly81/kafka-examples

Practical examples with Apache Kafka®

Language: Java - Size: 120 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 78 - Forks: 16

masesgroup/KNet

KNet is a comprehensive .NET suite for Apache Kafka™ providing all features: Producer, Consumer, Admin, Streams, Connect, backends (ZooKeeper and Kafka)

Language: C# - Size: 138 MB - Last synced at: 18 days ago - Pushed at: 22 days ago - Stars: 44 - Forks: 6

NAGARAJ08/kafka-replay

A CLI tool to fetch Kafka messages within a specified time range

Language: Python - Size: 9.77 KB - Last synced at: 24 days ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

danielsobrado/CCDAK-Exam-Questions

Confluent Kafka questions to practice for CCDAK

Size: 519 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 131 - Forks: 48

StephenSorriaux/ansible-kafka-admin

Manage your topic's configuration (partitions, replication factor, parameters), ACLs, quotas, users and get stats, without any effort with this library. It does not use the Kafka scripts and does not require ssh connection to the remote broker.

Language: Python - Size: 607 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 153 - Forks: 48

collectd/collectd

The system statistics collection daemon. Please send Pull Requests here!

Language: C - Size: 27.4 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 3,280 - Forks: 1,248

nomisRev/kotlin-kafka

Kafka bindings for Kotlin `suspend`, and Kafka streaming operators for KotlinX Flow.

Language: Kotlin - Size: 2.46 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 111 - Forks: 10

opentracing-contrib/java-specialagent

Automatic instrumentation for 3rd-party libraries in Java applications with OpenTracing.

Language: Java - Size: 9.17 MB - Last synced at: about 1 month ago - Pushed at: over 3 years ago - Stars: 186 - Forks: 44

provectus/kafka-ui

Open-Source Web UI for Apache Kafka Management

Language: Java - Size: 29 MB - Last synced at: about 1 month ago - Pushed at: 11 months ago - Stars: 10,773 - Forks: 1,272

twmb/kcl

Your one stop shop to do anything with Kafka. Producing, consuming, transacting, administrating; 0.8.0 through 3.2+

Language: Go - Size: 433 KB - Last synced at: about 1 month ago - Pushed at: about 2 months ago - Stars: 211 - Forks: 21

Castaglia/proftpd-mod_kafka

ProFTPD module for logging via Kafka

Language: C - Size: 170 KB - Last synced at: 12 days ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0

TIBCOSoftware/flogo

Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.

Language: CSS - Size: 32.4 MB - Last synced at: about 1 month ago - Pushed at: about 1 year ago - Stars: 2,459 - Forks: 291

joowani/kq

Kafka-based Job Queue for Python

Language: Python - Size: 108 KB - Last synced at: 6 days ago - Pushed at: over 3 years ago - Stars: 570 - Forks: 23

rafi021/kafka-docker-compose

Docker Composer File for Kafka and Test using Express JS

Language: TypeScript - Size: 7.25 MB - Last synced at: 14 days ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 1

php-enqueue/rdkafka

[READ-ONLY] The Kafka Enqueue transport.

Language: PHP - Size: 146 KB - Last synced at: about 1 month ago - Pushed at: about 2 months ago - Stars: 51 - Forks: 40

nayekabhishek1/awesome-kafka

A curated list about Apache Kafka

Size: 24.4 KB - Last synced at: about 2 months ago - Pushed at: almost 3 years ago - Stars: 17 - Forks: 7

phobos/phobos 📦

Simplifying Kafka for ruby apps

Language: Ruby - Size: 6.36 MB - Last synced at: 22 days ago - Pushed at: 2 months ago - Stars: 219 - Forks: 38

SimpleProgramming/springboot-kafka

A simple example to show how to use Spring Boot with Apache Kafka

Language: Java - Size: 13.7 KB - Last synced at: 6 days ago - Pushed at: about 3 years ago - Stars: 12 - Forks: 36

bootique/bootique-kafka

Provides integration of Kafka client and streams with Bootique

Language: Java - Size: 351 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 4 - Forks: 4

opentracing-contrib/java-kafka-client

OpenTracing Instrumentation for Apache Kafka Client

Language: Java - Size: 349 KB - Last synced at: about 1 month ago - Pushed at: almost 2 years ago - Stars: 128 - Forks: 64

nodefluent/node-sinek

:tophat: Most advanced high level Node.js Kafka client

Language: TypeScript - Size: 1.17 MB - Last synced at: 3 days ago - Pushed at: over 2 years ago - Stars: 291 - Forks: 52

source-c/clj-kafka-x

Clojure client for Apache Kafka

Language: Clojure - Size: 63.5 KB - Last synced at: 4 days ago - Pushed at: 2 months ago - Stars: 6 - Forks: 3

jSarthak-987/washub-nodejs-kafka-client-api

Apache Kafka client API for nodejs based services of Washub

Language: JavaScript - Size: 61.5 KB - Last synced at: 25 days ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0

oslabs-beta/kalibrate

An open-source GUI for managing and monitoring Kafka cluster health

Language: TypeScript - Size: 6.37 MB - Last synced at: 2 months ago - Pushed at: about 2 years ago - Stars: 59 - Forks: 3

LearningJournal/ApacheKafkaTutorials

Example Code for Kafka Tutorials @ Learning Journal

Language: Java - Size: 20.5 KB - Last synced at: about 1 month ago - Pushed at: over 7 years ago - Stars: 177 - Forks: 220

severstal-digital/wunderkafka

The power of librdkafka for pythons

Language: Python - Size: 1.49 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 4 - Forks: 1

chetanghadiya007/kafka_zookeeper_nodejs

Scalable Application Using Kafka, Zookeeper, and Node.js

Language: JavaScript - Size: 2.93 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0

LearningJournal/Kafka-Streams-Real-time-Stream-Processing

This is the central repository for all materials related to Kafka Streams : Real-time Stream Processing! Book by Prashant Pandey.

Language: Java - Size: 5.25 MB - Last synced at: 3 months ago - Pushed at: almost 5 years ago - Stars: 164 - Forks: 163

mkbeh/xkafka

library for working with Kafka, using franz-go and integration with OpenTelemetry for tracing and metrics. Producing, consuming, transacting, etc.

Language: Go - Size: 51.8 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0

kaiwaehner/ksql-udf-deep-learning-mqtt-iot

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

Language: Java - Size: 866 KB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 298 - Forks: 116

thangchung/practical-opentelemetry

Make OpenTelemetry works on .NET Core with features such as tracing, logs and metrics on multiple protocols like HTTP/gRPC/UDP/TCP...

Language: C# - Size: 2 MB - Last synced at: 2 months ago - Pushed at: over 2 years ago - Stars: 61 - Forks: 20

bonfaceidi/rd

"rd" is a command-line utility for deleting directories in Unix-based systems. It allows users to efficiently remove folders and their contents from the file system using simple commands.

Size: 1000 Bytes - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0

fhussonnois/kafka-examples

Examples of use of Apache Kafka Clients/KafkaStreams APIs

Language: Java - Size: 50.8 KB - Last synced at: 19 days ago - Pushed at: over 6 years ago - Stars: 13 - Forks: 15

ppatierno/kafka-playground

An Apache Kafka playground

Language: Java - Size: 61.5 KB - Last synced at: 22 days ago - Pushed at: 5 months ago - Stars: 5 - Forks: 1

Spinoco/fs2-kafka

Kafka client for functional streams for scala (fs2)

Language: Scala - Size: 260 KB - Last synced at: 3 months ago - Pushed at: almost 2 years ago - Stars: 77 - Forks: 14

stormaref/KafkaStorm

Simple .net client for Kafka based on Confluent.Kafka

Language: C# - Size: 59.6 KB - Last synced at: 22 days ago - Pushed at: 6 months ago - Stars: 3 - Forks: 0

imiphp/imi-kafka

支持在 imi 框架中使用 Kafka 客户端

Language: PHP - Size: 245 KB - Last synced at: about 4 hours ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0

skroutz/rafka

Kafka proxy with a simple API, speaking the Redis protocol

Language: Go - Size: 354 KB - Last synced at: 2 months ago - Pushed at: about 2 years ago - Stars: 10 - Forks: 0

rk8130/Kafka-Retail-Pipeline

Real-time data streaming project using Python, Pandas, and Confluent Kafka to publish and consume retail data through Kafka topics, demonstrating scalability and dynamic consumer behavior.

Language: Python - Size: 294 KB - Last synced at: 7 months ago - Pushed at: 7 months ago - Stars: 1 - Forks: 0

guoshiqiufeng/loki

Simplifying mq usage

Language: Java - Size: 617 KB - Last synced at: 4 months ago - Pushed at: about 1 year ago - Stars: 3 - Forks: 0

Csini/spring-kafka-extensions

spring-kafka-extensions is a library that makes an entity based reactive approach (rxjava) to apache kafka possible, if you are using spring

Language: Java - Size: 1.4 MB - Last synced at: 2 months ago - Pushed at: 8 months ago - Stars: 3 - Forks: 0

sripathikrishnan/redkaf

Kafka Client API implementation that instead write to Redis Streams

Language: Java - Size: 47.9 KB - Last synced at: 3 months ago - Pushed at: over 6 years ago - Stars: 7 - Forks: 1

luizcalaca/node-kafka-microservices

Node.js + Kafka + Microservices

Language: JavaScript - Size: 59.6 KB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 14 - Forks: 3

tayeva/librdkafka-examples-cpp

Examples using librdkafka

Language: C++ - Size: 51.8 KB - Last synced at: 3 months ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 0

kalduzov/nkafka

.net native kafka library

Language: C# - Size: 1.61 MB - Last synced at: 6 months ago - Pushed at: 6 months ago - Stars: 6 - Forks: 0

soundvibe/kafka-config

Typesafe configuration for Kafka clients

Language: Java - Size: 95.7 KB - Last synced at: 2 months ago - Pushed at: 10 months ago - Stars: 2 - Forks: 0

clj-kafka/franzy

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

Language: Clojure - Size: 332 KB - Last synced at: 2 days ago - Pushed at: about 7 years ago - Stars: 22 - Forks: 5

ciena/afkak

Kafka client written in Twisted Python

Language: Python - Size: 1.57 MB - Last synced at: 16 days ago - Pushed at: almost 2 years ago - Stars: 32 - Forks: 23

kaiwaehner/kafka-streams-machine-learning-examples

This project contains examples which demonstrate how to deploy analytic models to mission-critical, scalable production environments leveraging Apache Kafka and its Streams API. Models are built with Python, H2O, TensorFlow, Keras, DeepLearning4 and other technologies.

Language: Java - Size: 51.5 MB - Last synced at: 11 months ago - Pushed at: over 1 year ago - Stars: 834 - Forks: 304

wesleysbmartins/go_kafka

Este é um exemplo de como uma aplicação Golang pode trabalhar integrada ao Kafka.

Language: Go - Size: 22.5 KB - Last synced at: 3 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

cloudintro/python-elasticsearch-with-kafka

Python Restful service with elasticsearch and kafka integration

Language: Python - Size: 22.5 KB - Last synced at: 12 months ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

euiyounghwang/kafka_job_interface_service

kafka_job_interface_service

Language: Python - Size: 47.9 KB - Last synced at: 2 days ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

maximepeschard/kafkadog

:dog: A Kafka consumer/producer CLI

Language: Go - Size: 29.3 KB - Last synced at: about 1 year ago - Pushed at: about 5 years ago - Stars: 2 - Forks: 1

gocollection/kafka-go

make your kafka integration easy with kafka-go (supports Kafka v0.8 - v2.3)

Language: Go - Size: 48.8 KB - Last synced at: about 1 year ago - Pushed at: almost 4 years ago - Stars: 11 - Forks: 2

danielwegener/logback-kafka-appender 📦

Logback appender for Apache Kafka

Language: Java - Size: 249 KB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 635 - Forks: 261

openweb-nl/kafka-graphql-examples

A platform to test solutions for using Kafka with Graphql

Language: Clojure - Size: 46.1 MB - Last synced at: 3 months ago - Pushed at: about 5 years ago - Stars: 60 - Forks: 11

ashimjk/apache-kafka-series

Apache Kafka Series

Language: Java - Size: 246 KB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 0

Bronya0/Kafka-King

A modern and practical kafka GUI client | 一个现代、实用的kafka界面客户端。

Language: Python - Size: 2.62 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 97 - Forks: 3

oscaro/felice

Felice is a simple client library for Apache Kafka in Clojure, with JSON, Transit, Nippy and more!

Language: Clojure - Size: 724 KB - Last synced at: 12 days ago - Pushed at: about 1 year ago - Stars: 8 - Forks: 2

opt-nc/atelier-spring-kafka

Projet d'exemple d'utilisation de la lib `org.springframework.kafka:spring-kafka`

Language: Java - Size: 16.7 MB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 2

ahiv/kafka-client

Language: C++ - Size: 66.4 KB - Last synced at: about 1 year ago - Pushed at: about 5 years ago - Stars: 1 - Forks: 0

lepetitprinz/apache-kafka

Hands-on learning Apache Kafka

Language: Java - Size: 86.9 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0

kodtodya/kafka-beginner-sessions

This repository contains the Kafka Clients and broker configuration details and notes for beginner level

Language: Java - Size: 816 KB - Last synced at: about 1 year ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 0

schaffung/mqtt_kafka_connect

A medium for linking mqtt to kafka

Language: Python - Size: 10.7 KB - Last synced at: 3 months ago - Pushed at: almost 6 years ago - Stars: 2 - Forks: 0

tejasjadhav/nkafka

Kafka client for Nim

Language: Nim - Size: 74.2 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 0

pkazi/Dockerfiles

Dockerfiles for various simple docker images.

Language: Shell - Size: 10.7 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 1

getspacetime/spacetime

A fully featured cross-platform API Client for REST, gRPC, and more. Built with .NET MAUI Blazor

Language: C# - Size: 24.6 MB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 56 - Forks: 10

sgerrand/alpine-pkg-kafkacat 📦

Kafkacat packaged for Alpine Linux

Size: 25.4 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 10 - Forks: 2

taion809/transceiver

Kafka pub sub convenience

Language: Go - Size: 7.81 KB - Last synced at: about 1 year ago - Pushed at: about 8 years ago - Stars: 0 - Forks: 0

techmonad/tweet-publisher-to-kafka

This is a sbt project to describes how to pull tweets from twitter and publish into Kafka.

Language: Scala - Size: 5.86 KB - Last synced at: over 1 year ago - Pushed at: almost 7 years ago - Stars: 1 - Forks: 0

uptake/fRanz

R client for Apache Kafka

Language: R - Size: 176 KB - Last synced at: 14 days ago - Pushed at: about 6 years ago - Stars: 19 - Forks: 6

BaseMax/KafkaDataProcessingGo

Welcome to the Kafka Data Processing with Go project! This project showcases how to use Apache Kafka in combination with the Go programming language to build a data processing application.

Language: Go - Size: 44.9 KB - Last synced at: 8 days ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0