hifly81/kafka-examples

Practical examples with Apache Kafka®

Language: Java - Size: 120 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 76 - Forks: 15

confluentinc/confluent-kafka-dotnet

Confluent's Apache Kafka .NET client

Language: C# - Size: 6.26 MB - Last synced at: about 21 hours ago - Pushed at: 2 days ago - Stars: 153 - Forks: 879

IBM/sarama

Sarama is a Go library for Apache Kafka.

Language: Go - Size: 10 MB - Last synced at: 1 day ago - Pushed at: 8 days ago - Stars: 11,921 - Forks: 1,791

strimzi/strimzi-kafka-bridge

An HTTP bridge for Apache Kafka®

Language: Java - Size: 2.61 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 305 - Forks: 125

confluentinc/confluent-kafka-python

Confluent's Kafka Python Client

Language: Python - Size: 14.1 MB - Last synced at: about 23 hours ago - Pushed at: 2 days ago - Stars: 257 - Forks: 913

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.48 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 1,416 - Forks: 384

tulios/kafkajs

A modern Apache Kafka client for node.js

Language: JavaScript - Size: 11.3 MB - Last synced at: 1 day ago - Pushed at: 9 months ago - Stars: 3,857 - Forks: 554

karafka/karafka

Ruby and Rails efficient Kafka processing framework

Language: Ruby - Size: 6.36 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 2,150 - Forks: 184

aio-libs/aiokafka

asyncio client for kafka

Language: Python - Size: 3.2 MB - Last synced at: 2 days ago - Pushed at: 11 days ago - Stars: 1,232 - Forks: 239

provectus/kafka-ui

Open-Source Web UI for Apache Kafka Management

Language: Java - Size: 29 MB - Last synced at: 2 days ago - Pushed at: 9 months ago - Stars: 10,654 - Forks: 1,267

fede1024/rust-rdkafka

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

Language: Rust - Size: 14.3 MB - Last synced at: 2 days ago - Pushed at: 3 months ago - Stars: 1,746 - Forks: 301

segmentio/kafka-go

Kafka library in Go

Language: Go - Size: 2.13 MB - Last synced at: 2 days ago - Pushed at: 14 days ago - Stars: 7,922 - Forks: 805

jonas-grgt/ktea

Kafka TUI client

Language: Go - Size: 1.24 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 14 - Forks: 2

confluentinc/confluent-kafka-go

Confluent's Apache Kafka Golang client

Language: HTML - Size: 498 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 4,828 - Forks: 678

bootique/bootique-kafka

Provides integration of Kafka client and streams with Bootique

Language: Java - Size: 348 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 4 - Forks: 4

kafbat/kafka-ui

Open-Source Web UI for managing Apache Kafka clusters

Language: Java - Size: 34.6 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 1,019 - Forks: 132

confluentinc/confluent-kafka-javascript

Confluent's Apache Kafka JavaScript client

Language: JavaScript - Size: 5.42 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 155 - Forks: 14

Farfetch/kafkaflow

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

Language: C# - Size: 23.4 MB - Last synced at: 6 days ago - Pushed at: 8 days ago - Stars: 716 - Forks: 124

twmb/franz-go

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

Language: Go - Size: 5.35 MB - Last synced at: 7 days ago - Pushed at: 8 days ago - Stars: 2,073 - Forks: 218

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.31 MB - Last synced at: 6 days ago - Pushed at: 10 days ago - Stars: 26 - Forks: 13

fd4s/fs2-kafka

Functional Kafka Streams for Scala

Language: Scala - Size: 12 MB - Last synced at: 10 days ago - Pushed at: 15 days ago - Stars: 297 - Forks: 105

source-c/clj-kafka-x

Clojure client for Apache Kafka

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

zendesk/ruby-kafka

A Ruby client library for Apache Kafka

Language: Ruby - Size: 2.11 MB - Last synced at: 7 days ago - Pushed at: about 2 years ago - Stars: 1,275 - Forks: 339

nomisRev/kotlin-kafka

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

Language: Kotlin - Size: 2.45 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 110 - Forks: 10

3axap4eHko/kafka-console

CLI kafka client

Language: TypeScript - Size: 953 KB - Last synced at: 14 days ago - Pushed at: 14 days ago - Stars: 4 - Forks: 2

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: 11 days ago - Pushed at: 12 months ago - Stars: 2,454 - Forks: 289

arnaud-lb/php-rdkafka

Production-ready, stable Kafka client for PHP

Language: C - Size: 974 KB - Last synced at: 14 days ago - Pushed at: about 2 months ago - Stars: 2,132 - Forks: 266

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: 134 MB - Last synced at: 15 days ago - Pushed at: 15 days ago - Stars: 45 - Forks: 6

FundingCircle/jackdaw

A Clojure library for the Apache Kafka distributed streaming platform.

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

floydspace/effect-kafka

📨 Effectful Kafka

Language: TypeScript - Size: 643 KB - Last synced at: 4 days ago - Pushed at: 3 months ago - Stars: 13 - Forks: 2

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: 764 KB - Last synced at: 5 days ago - Pushed at: 20 days ago - Stars: 22 - Forks: 0

Bogdanp/Franz

A desktop client for Apache Kafka.

Language: Racket - Size: 9.92 MB - Last synced at: 19 days ago - Pushed at: about 2 months ago - Stars: 141 - Forks: 2

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: 311 KB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 1 - Forks: 0

NAGARAJ08/kafka-replay

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

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

opentracing-contrib/java-kafka-client

OpenTracing Instrumentation for Apache Kafka Client

Language: Java - Size: 349 KB - Last synced at: 12 days ago - Pushed at: over 1 year ago - Stars: 127 - Forks: 64

oslabs-beta/kalibrate

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

Language: TypeScript - Size: 6.37 MB - Last synced at: 16 days ago - Pushed at: almost 2 years ago - Stars: 59 - Forks: 3

joowani/kq

Kafka-based Job Queue for Python

Language: Python - Size: 108 KB - Last synced at: 12 days ago - Pushed at: about 3 years ago - Stars: 572 - Forks: 23

LearningJournal/ApacheKafkaTutorials

Example Code for Kafka Tutorials @ Learning Journal

Language: Java - Size: 20.5 KB - Last synced at: 15 days ago - Pushed at: over 7 years ago - Stars: 177 - Forks: 220

php-enqueue/rdkafka

[READ-ONLY] The Kafka Enqueue transport.

Language: PHP - Size: 142 KB - Last synced at: 15 days ago - Pushed at: 3 months ago - Stars: 51 - Forks: 39

severstal-digital/wunderkafka

The power of librdkafka for pythons

Language: Python - Size: 1.49 MB - Last synced at: 13 days ago - Pushed at: 13 days 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: about 1 month ago - Pushed at: about 1 month 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: 11 days ago - Pushed at: over 4 years ago - Stars: 164 - Forks: 163

twmb/kcl

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

Language: Go - Size: 458 KB - Last synced at: 12 days ago - Pushed at: about 1 year ago - Stars: 208 - Forks: 21

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: about 2 months ago - Pushed at: about 2 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: 28 days ago - Pushed at: over 1 year ago - Stars: 298 - Forks: 116

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: 565 KB - Last synced at: 20 days ago - Pushed at: about 2 months ago - Stars: 151 - Forks: 46

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: 6 days 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: 2 months ago - Pushed at: 2 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: 20 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: 3 months ago - Stars: 5 - Forks: 1

danielsobrado/CCDAK-Exam-Questions

Confluent Kafka questions to practice for CCDAK

Size: 335 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 90 - Forks: 32

Spinoco/fs2-kafka

Kafka client for functional streams for scala (fs2)

Language: Scala - Size: 260 KB - Last synced at: 20 days 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: 4 months ago - Stars: 3 - Forks: 0

imiphp/imi-kafka

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

Language: PHP - Size: 245 KB - Last synced at: 10 days 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: 20 days 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: 4 months ago - Pushed at: 5 months ago - Stars: 1 - Forks: 0

guoshiqiufeng/loki

Simplifying mq usage

Language: Java - Size: 617 KB - Last synced at: about 2 months ago - Pushed at: 10 months 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: 5 days ago - Pushed at: 6 months ago - Stars: 3 - Forks: 0

BSVN/Commons

Commons library

Language: C# - Size: 5.31 MB - Last synced at: 15 days ago - Pushed at: 6 months ago - Stars: 7 - Forks: 8

sripathikrishnan/redkaf

Kafka Client API implementation that instead write to Redis Streams

Language: Java - Size: 47.9 KB - Last synced at: 10 days ago - Pushed at: about 6 years ago - Stars: 7 - Forks: 1

luizcalaca/node-kafka-microservices

Node.js + Kafka + Microservices

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

nodefluent/node-sinek

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

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

dropwizard/dropwizard-kafka

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

Language: Java - Size: 469 KB - Last synced at: 6 months ago - Pushed at: 6 months ago - Stars: 21 - Forks: 12

tayeva/librdkafka-examples-cpp

Examples using librdkafka

Language: C++ - Size: 51.8 KB - Last synced at: 18 days ago - Pushed at: almost 2 years ago - Stars: 1 - Forks: 0

kalduzov/nkafka

.net native kafka library

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

soundvibe/kafka-config

Typesafe configuration for Kafka clients

Language: Java - Size: 95.7 KB - Last synced at: 3 days ago - Pushed at: 8 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: 4 months ago - Pushed at: almost 7 years ago - Stars: 22 - Forks: 5

opentracing-contrib/java-specialagent

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

Language: Java - Size: 9.17 MB - Last synced at: 19 days ago - Pushed at: over 3 years ago - Stars: 185 - Forks: 46

ciena/afkak

Kafka client written in Twisted Python

Language: Python - Size: 1.57 MB - Last synced at: 19 days ago - Pushed at: over 1 year ago - Stars: 32 - Forks: 22

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: 9 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: about 1 month ago - Pushed at: 9 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: 10 months ago - Pushed at: about 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: about 1 month ago - Pushed at: 10 months ago - Stars: 0 - Forks: 0

maximepeschard/kafkadog

:dog: A Kafka consumer/producer CLI

Language: Go - Size: 29.3 KB - Last synced at: 10 months ago - Pushed at: almost 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: 10 months ago - Pushed at: over 3 years ago - Stars: 11 - Forks: 2

phobos/phobos

Simplifying Kafka for ruby apps

Language: Ruby - Size: 6.35 MB - Last synced at: 11 months ago - Pushed at: over 1 year ago - Stars: 219 - Forks: 38

danielwegener/logback-kafka-appender 📦

Logback appender for Apache Kafka

Language: Java - Size: 249 KB - Last synced at: 10 months ago - Pushed at: almost 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: 16 days ago - Pushed at: almost 5 years ago - Stars: 60 - Forks: 11

ashimjk/apache-kafka-series

Apache Kafka Series

Language: Java - Size: 246 KB - Last synced at: 11 months ago - Pushed at: almost 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: 10 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: 25 days ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 2

ahiv/kafka-client

Language: C++ - Size: 66.4 KB - Last synced at: 11 months ago - Pushed at: almost 5 years ago - Stars: 1 - Forks: 0

lepetitprinz/apache-kafka

Hands-on learning Apache Kafka

Language: Java - Size: 86.9 KB - Last synced at: 12 months 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: 12 months 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: 26 days ago - Pushed at: over 5 years ago - Stars: 2 - Forks: 0

tejasjadhav/nkafka

Kafka client for Nim

Language: Nim - Size: 74.2 KB - Last synced at: 12 months ago - Pushed at: about 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: about 3 years ago - Stars: 0 - Forks: 1

collectd/collectd

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

Language: C - Size: 27.7 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 2,974 - Forks: 1,227

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: 12 months 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: 12 months 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: almost 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: about 1 year ago - Pushed at: almost 7 years ago - Stars: 1 - Forks: 0

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: 3 days ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0

Trendyol/goncolos

Goncolos is simple wrapper top of confluent-kafka-dotnet

Language: C# - Size: 50.8 KB - Last synced at: about 1 month ago - Pushed at: 3 months ago - Stars: 4 - Forks: 1

harshit-budhraja/kafka_handler

A simple Kafka wrapper based on confluent_kafka python client.

Language: Python - Size: 26.4 KB - Last synced at: 8 days ago - Pushed at: almost 5 years ago - Stars: 2 - Forks: 0

muathendirangu/streaming-twitter-data-kafka-elastic-search

A lab done to demonstrate understanding of using kafka via a java client

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

Vijendra07Kulhade/kafkademoapp

Language: Java - Size: 6.84 KB - Last synced at: about 1 year ago - Pushed at: almost 8 years ago - Stars: 0 - Forks: 0

telkomdev/kafka-cli

Kafka command line client written in Go

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

oslabs-beta/kafkaSaur

Apache Kafka client for Deno

Language: TypeScript - Size: 2.37 MB - Last synced at: 16 days ago - Pushed at: over 3 years ago - Stars: 45 - Forks: 5