Topic: "kafka-client"
IBM/sarama
Sarama is a Go library for Apache Kafka.
Language: Go - Size: 10 MB - Last synced at: about 1 hour ago - Pushed at: 6 days ago - Stars: 11,920 - Forks: 1,791
provectus/kafka-ui
Open-Source Web UI for Apache Kafka Management
Language: Java - Size: 29 MB - Last synced at: about 14 hours ago - Pushed at: 9 months ago - Stars: 10,654 - Forks: 1,267
segmentio/kafka-go
Kafka library in Go
Language: Go - Size: 2.13 MB - Last synced at: about 13 hours ago - Pushed at: 12 days ago - Stars: 7,922 - Forks: 805
confluentinc/confluent-kafka-go
Confluent's Apache Kafka Golang client
Language: HTML - Size: 498 MB - Last synced at: about 14 hours ago - Pushed at: about 21 hours ago - Stars: 4,828 - Forks: 678
tulios/kafkajs
A modern Apache Kafka client for node.js
Language: JavaScript - Size: 11.3 MB - Last synced at: about 1 hour ago - Pushed at: 9 months ago - Stars: 3,857 - Forks: 554
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
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: 9 days ago - Pushed at: 12 months ago - Stars: 2,454 - Forks: 289
karafka/karafka
Ruby and Rails efficient Kafka processing framework
Language: Ruby - Size: 6.36 MB - Last synced at: about 4 hours ago - Pushed at: about 9 hours ago - Stars: 2,150 - Forks: 184
arnaud-lb/php-rdkafka
Production-ready, stable Kafka client for PHP
Language: C - Size: 974 KB - Last synced at: 12 days ago - Pushed at: about 2 months ago - Stars: 2,132 - Forks: 266
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: 6 days ago - Pushed at: 6 days ago - Stars: 2,073 - Forks: 218
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: about 7 hours ago - Pushed at: 3 months ago - Stars: 1,746 - Forks: 301
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: about 5 hours ago - Pushed at: about 6 hours ago - Stars: 1,416 - Forks: 384
zendesk/ruby-kafka
A Ruby client library for Apache Kafka
Language: Ruby - Size: 2.11 MB - Last synced at: 6 days ago - Pushed at: about 2 years ago - Stars: 1,275 - Forks: 339
aio-libs/aiokafka
asyncio client for kafka
Language: Python - Size: 3.2 MB - Last synced at: about 4 hours ago - Pushed at: 9 days ago - Stars: 1,232 - Forks: 239
kafbat/kafka-ui
Open-Source Web UI for managing Apache Kafka clusters
Language: Java - Size: 34.6 MB - Last synced at: 3 days ago - Pushed at: 4 days ago - Stars: 1,019 - Forks: 132
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
Farfetch/kafkaflow
Apache Kafka .NET Framework to create applications simple to use and extend.
Language: C# - Size: 23.4 MB - Last synced at: 4 days ago - Pushed at: 6 days ago - Stars: 716 - Forks: 124
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
joowani/kq
Kafka-based Job Queue for Python
Language: Python - Size: 108 KB - Last synced at: 10 days ago - Pushed at: about 3 years ago - Stars: 572 - Forks: 23
FundingCircle/jackdaw
A Clojure library for the Apache Kafka distributed streaming platform.
Language: Clojure - Size: 1.83 MB - Last synced at: 8 days ago - Pushed at: 8 months ago - Stars: 374 - Forks: 78
strimzi/strimzi-kafka-bridge
An HTTP bridge for Apache Kafka®
Language: Java - Size: 2.59 MB - Last synced at: 9 days ago - Pushed at: 19 days ago - Stars: 304 - Forks: 125
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: 26 days ago - Pushed at: over 1 year ago - Stars: 298 - Forks: 116
fd4s/fs2-kafka
Functional Kafka Streams for Scala
Language: Scala - Size: 12 MB - Last synced at: 8 days ago - Pushed at: 14 days ago - Stars: 297 - Forks: 105
nodefluent/node-sinek
:tophat: Most advanced high level Node.js Kafka client
Language: TypeScript - Size: 1.17 MB - Last synced at: 19 days ago - Pushed at: over 2 years ago - Stars: 290 - Forks: 52
confluentinc/confluent-kafka-python
Confluent's Kafka Python Client
Language: Python - Size: 13.9 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 250 - Forks: 911
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
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: 10 days ago - Pushed at: about 1 year ago - Stars: 208 - Forks: 21
opentracing-contrib/java-specialagent
Automatic instrumentation for 3rd-party libraries in Java applications with OpenTracing.
Language: Java - Size: 9.17 MB - Last synced at: 17 days ago - Pushed at: over 3 years ago - Stars: 185 - Forks: 46
LearningJournal/ApacheKafkaTutorials
Example Code for Kafka Tutorials @ Learning Journal
Language: Java - Size: 20.5 KB - Last synced at: 13 days ago - Pushed at: over 7 years ago - Stars: 177 - Forks: 220
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: 10 days ago - Pushed at: over 4 years ago - Stars: 164 - Forks: 163
confluentinc/confluent-kafka-javascript
Confluent's Apache Kafka JavaScript client
Language: JavaScript - Size: 5.42 MB - Last synced at: 4 days ago - Pushed at: 5 days ago - Stars: 155 - Forks: 14
confluentinc/confluent-kafka-dotnet
Confluent's Apache Kafka .NET client
Language: C# - Size: 6.02 MB - Last synced at: 8 days ago - Pushed at: 9 days ago - Stars: 152 - Forks: 879
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: 19 days ago - Pushed at: about 2 months ago - Stars: 151 - Forks: 46
Bogdanp/Franz
A desktop client for Apache Kafka.
Language: Racket - Size: 9.92 MB - Last synced at: 17 days ago - Pushed at: about 2 months ago - Stars: 141 - Forks: 2
opentracing-contrib/java-kafka-client
OpenTracing Instrumentation for Apache Kafka Client
Language: Java - Size: 349 KB - Last synced at: 11 days ago - Pushed at: over 1 year ago - Stars: 127 - Forks: 64
nomisRev/kotlin-kafka
Kafka bindings for Kotlin `suspend`, and Kafka streaming operators for KotlinX Flow.
Language: Kotlin - Size: 2.45 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 110 - Forks: 10
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
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: 18 days ago - Pushed at: over 1 year ago - Stars: 77 - Forks: 14
hifly81/kafka-examples
Practical examples with Apache Kafka®
Language: Java - Size: 120 MB - Last synced at: 15 days ago - Pushed at: about 1 month ago - Stars: 76 - Forks: 15
freakchick/kafkaUI-lite
史上最轻便好用的kafka 可视化图形界面客户端工具，可以生产消费消息，管理topic、group、集群。支持管理多个kafka环境。同时支持zookeeper redis 图形化界面操作
Language: Vue - Size: 1.27 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 71 - Forks: 24
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: 4 days ago - Pushed at: over 2 years ago - Stars: 61 - Forks: 20
openweb-nl/kafka-graphql-examples
A platform to test solutions for using Kafka with Graphql
Language: Clojure - Size: 46.1 MB - Last synced at: 15 days ago - Pushed at: almost 5 years ago - Stars: 60 - Forks: 11
oslabs-beta/kalibrate
An open-source GUI for managing and monitoring Kafka cluster health
Language: TypeScript - Size: 6.37 MB - Last synced at: 15 days ago - Pushed at: almost 2 years ago - Stars: 59 - Forks: 3
WallarooLabs/pony-kafka
:horse: Pure Pony Kafka client
Language: Pony - Size: 630 KB - Last synced at: about 2 months ago - Pushed at: about 6 years ago - Stars: 57 - Forks: 4
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
php-enqueue/rdkafka
[READ-ONLY] The Kafka Enqueue transport.
Language: PHP - Size: 142 KB - Last synced at: 13 days ago - Pushed at: 3 months ago - Stars: 51 - Forks: 39
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: 13 days ago - Pushed at: 13 days ago - Stars: 45 - Forks: 6
oslabs-beta/kafkaSaur
Apache Kafka client for Deno
Language: TypeScript - Size: 2.37 MB - Last synced at: 15 days ago - Pushed at: over 3 years ago - Stars: 45 - Forks: 5
ciena/afkak
Kafka client written in Twisted Python
Language: Python - Size: 1.57 MB - Last synced at: 18 days ago - Pushed at: over 1 year ago - Stars: 32 - Forks: 22
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: 4 days ago - Pushed at: 8 days ago - Stars: 26 - Forks: 13
snmslavk/kafka-net-core
kafka .net core library
Language: C# - Size: 68.4 KB - Last synced at: 13 days ago - Pushed at: over 5 years ago - Stars: 25 - Forks: 6
php-enqueue/magento-enqueue
The extension adds messaging capabilities to Magento1 application.
Language: PHP - Size: 25.4 KB - Last synced at: 3 days ago - Pushed at: over 7 years ago - Stars: 24 - Forks: 8
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: 4 days ago - Pushed at: 18 days ago - Stars: 22 - 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
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
alshpak/kafka_data_viewer
Tool that providing ability to access kafka data - query items in topics and kafka metadata
Language: Scala - Size: 358 KB - Last synced at: about 2 years ago - Pushed at: over 5 years ago - Stars: 21 - Forks: 5
uptake/fRanz
R client for Apache Kafka
Language: R - Size: 176 KB - Last synced at: about 2 years ago - Pushed at: almost 6 years ago - Stars: 18 - Forks: 7
simplesteph/kafka-0.11-examples
Code snippets that demonstrate how to leverage the new Kafka 0.11 APIs
Language: Scala - Size: 5.86 KB - Last synced at: about 2 years ago - Pushed at: over 7 years ago - Stars: 17 - Forks: 7
nayekabhishek1/awesome-kafka
A curated list about Apache Kafka
Size: 24.4 KB - Last synced at: 6 days ago - Pushed at: over 2 years ago - Stars: 16 - Forks: 7
heimuheimu/naiveasync
对 Kafka 生产者和消费者进行封装，提供实时报警和数据监控功能。
Language: Java - Size: 358 KB - Last synced at: about 1 year ago - Pushed at: almost 3 years ago - Stars: 15 - Forks: 5
jonas-grgt/ktea
Kafka TUI client
Language: Go - Size: 1.24 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 14 - Forks: 2
luizcalaca/node-kafka-microservices
Node.js + Kafka + Microservices
Language: JavaScript - Size: 59.6 KB - Last synced at: 22 days ago - Pushed at: over 2 years ago - Stars: 14 - Forks: 3
floydspace/effect-kafka
📨 Effectful Kafka
Language: TypeScript - Size: 643 KB - Last synced at: 3 days ago - Pushed at: 3 months ago - Stars: 13 - Forks: 2
alpari-tech/kafka-client
[WIP] Implementation of Kafka Client in PHP
Language: PHP - Size: 404 KB - Last synced at: 8 days ago - Pushed at: over 5 years ago - Stars: 13 - Forks: 2
fhussonnois/kafka-examples
Examples of use of Apache Kafka Clients/KafkaStreams APIs
Language: Java - Size: 50.8 KB - Last synced at: 18 days ago - Pushed at: over 6 years ago - Stars: 13 - Forks: 15
Mayvenn/kafka-component
A component to consume with many threads from Kafka
Language: Clojure - Size: 233 KB - Last synced at: about 7 hours ago - Pushed at: almost 2 years ago - Stars: 12 - Forks: 1
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: about 2 years ago - Pushed at: about 3 years ago - Stars: 11 - Forks: 35
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
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
skroutz/rafka
Kafka proxy with a simple API, speaking the Redis protocol
Language: Go - Size: 354 KB - Last synced at: 18 days ago - Pushed at: about 2 years ago - Stars: 10 - Forks: 0
botsunit/kafe Fork of G-Corp/kafe
A Kafka client in pure Erlang
Language: Erlang - Size: 4 MB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 10 - Forks: 5
dselivanov/rscalaKafka 📦
Tiny R kafka client with rscala
Language: R - Size: 13.3 MB - Last synced at: 6 days ago - Pushed at: about 8 years ago - Stars: 10 - Forks: 3
huangyueranbbc/KafkaDemo
Kafka整理
Language: Java - Size: 97.7 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 9 - Forks: 8
thejasbabu/kafka-example
A simple Kafka Consumer and Producer example
Language: Java - Size: 9.77 KB - Last synced at: over 1 year ago - Pushed at: almost 7 years ago - Stars: 9 - Forks: 20
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: 8 days ago - Pushed at: about 1 year ago - Stars: 8 - Forks: 2
gnu-gnu/kafractive
Kafractive is interative CLI tool for kafka admin, built on top of Spring Shell
Language: Java - Size: 85 KB - Last synced at: almost 2 years ago - Pushed at: over 5 years ago - Stars: 8 - Forks: 4
charles-hsiao/robotframework-kafka
A Kafka python library for Robotframework to test events(messages) in Kafka.
Language: Python - Size: 3.91 KB - Last synced at: 16 days ago - Pushed at: about 7 years ago - Stars: 8 - Forks: 5
BSVN/Commons
Commons library
Language: C# - Size: 5.31 MB - Last synced at: 13 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: 9 days ago - Pushed at: about 6 years ago - Stars: 7 - Forks: 1
jlandersen/kafka-control
web based management ui for kafka
Language: TypeScript - Size: 651 KB - Last synced at: about 2 years ago - Pushed at: over 6 years ago - Stars: 7 - Forks: 1
source-c/clj-kafka-x
Clojure client for Apache Kafka
Language: Clojure - Size: 63.5 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 6 - Forks: 3
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
streamthoughts/kafka-connect-client
Java client library for Apache Kafka Connect REST Interface
Language: Java - Size: 125 KB - Last synced at: almost 2 years ago - Pushed at: about 4 years ago - Stars: 6 - Forks: 4
ppatierno/kafka-playground
An Apache Kafka playground
Language: Java - Size: 61.5 KB - Last synced at: 20 days ago - Pushed at: 3 months ago - Stars: 5 - Forks: 1
ideasbucketlabs/tansen
Easy way to inspect, analyze and visualize Kafka Cluster, Topics and Schema
Language: Vue - Size: 881 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 5 - Forks: 0
mdvx/kafka-rtd
Excel RTD server sourcing data from Kafka
Language: C# - Size: 102 KB - Last synced at: about 2 years ago - Pushed at: almost 7 years ago - Stars: 5 - Forks: 3
nachomdo/panpipes
A tool inspired by NetCat to move data between remote and local Kafka clusters
Language: Go - Size: 137 KB - Last synced at: about 2 years ago - Pushed at: about 7 years ago - Stars: 5 - Forks: 1
bootique/bootique-kafka
Provides integration of Kafka client and streams with Bootique
Language: Java - Size: 348 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 4 - Forks: 4
severstal-digital/wunderkafka
The power of librdkafka for pythons
Language: Python - Size: 1.49 MB - Last synced at: 11 days ago - Pushed at: 12 days ago - Stars: 4 - Forks: 1
3axap4eHko/kafka-console
CLI kafka client
Language: TypeScript - Size: 953 KB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 4 - Forks: 2
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
godaner/brokerc
brokerc is a cross-platform publish and subscribe command line client tool, including mqtt client, amqp client, kafka client, http client.
Language: Go - Size: 111 MB - Last synced at: 10 months ago - Pushed at: about 4 years ago - Stars: 4 - Forks: 0
tmcgrath/kafka-examples
Wait for it.... Kafka Examples!
Language: Scala - Size: 10.7 KB - Last synced at: over 1 year ago - Pushed at: over 5 years ago - Stars: 4 - Forks: 1
Technoboy-/kafka-proxy-server
kafka-proxy-server is a wrapped consumer to consume kafka topic and dispatch message to real consumers
Language: Java - Size: 832 KB - Last synced at: about 2 years ago - Pushed at: about 6 years ago - Stars: 4 - Forks: 1
stormaref/KafkaStorm
Simple .net client for Kafka based on Confluent.Kafka
Language: C# - Size: 59.6 KB - Last synced at: 21 days ago - Pushed at: 4 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: 3 days ago - Pushed at: 6 months ago - Stars: 3 - 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
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
soundvibe/kafka-config
Typesafe configuration for Kafka clients
Language: Java - Size: 95.7 KB - Last synced at: 1 day ago - Pushed at: 7 months ago - Stars: 2 - Forks: 0
