confluentinc/confluent-kafka-javascript

Confluent's Apache Kafka JavaScript client

Language: JavaScript - Size: 1.81 MB - Last synced: about 6 hours ago - Pushed: about 17 hours ago - Stars: 74 - Forks: 4

danielsobrado/CCDAK-Exam-Questions

Confluent Kafka questions to practice for CCDAK

Size: 365 KB - Last synced: about 14 hours ago - Pushed: about 14 hours ago - Stars: 1 - Forks: 0

3axap4eHko/kafka-console

CLI kafka client

Language: TypeScript - Size: 978 KB - Last synced: about 17 hours ago - Pushed: about 18 hours ago - Stars: 4 - Forks: 2

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.23 MB - Last synced: about 17 hours ago - Pushed: about 18 hours ago - Stars: 20 - Forks: 10

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: 93.7 MB - Last synced: 1 day ago - Pushed: 1 day ago - Stars: 28 - Forks: 6

strimzi/strimzi-kafka-bridge

An HTTP bridge for Apache Kafka®

Language: Java - Size: 2.43 MB - Last synced: about 12 hours ago - Pushed: 2 days ago - Stars: 263 - Forks: 118

bootique/bootique-kafka

Provides integration of Kafka client and streams with Bootique

Language: Java - Size: 334 KB - Last synced: 7 days ago - Pushed: 8 days ago - Stars: 4 - Forks: 4

fd4s/fs2-kafka

Functional Kafka Streams for Scala

Language: Scala - Size: 11.3 MB - Last synced: 7 days ago - Pushed: 7 days ago - Stars: 286 - Forks: 97

Bronya0/Kafka-King

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

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

zendesk/ruby-kafka

A Ruby client library for Apache Kafka

Language: Ruby - Size: 2.11 MB - Last synced: 6 days ago - Pushed: about 1 year ago - Stars: 1,264 - Forks: 341

IBM/sarama

Sarama is a Go library for Apache Kafka.

Language: Go - Size: 10.2 MB - Last synced: 9 days ago - Pushed: 11 days ago - Stars: 11,026 - Forks: 1,718

segmentio/kafka-go

Kafka library in Go

Language: Go - Size: 2.12 MB - Last synced: 10 days ago - Pushed: 17 days ago - Stars: 7,160 - Forks: 749

twmb/franz-go

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

Language: Go - Size: 4.48 MB - Last synced: 10 days ago - Pushed: 10 days ago - Stars: 1,494 - Forks: 152

Bogdanp/Franz

A desktop client for Apache Kafka.

Language: Racket - Size: 9.88 MB - Last synced: 11 days ago - Pushed: 24 days ago - Stars: 104 - Forks: 2

lepetitprinz/apache-kafka

Hands-on learning Apache Kafka

Language: Java - Size: 86.9 KB - Last synced: 12 days ago - Pushed: about 1 year 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: 12 days ago - Pushed: over 5 years ago - Stars: 0 - Forks: 0

joowani/kq

Kafka-based Job Queue for Python

Language: Python - Size: 108 KB - Last synced: 5 days ago - Pushed: over 2 years ago - Stars: 572 - Forks: 24

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: 6 days ago - Pushed: 2 months ago - Stars: 186 - Forks: 19

Liberxue/binlog-kafka-java

TiDB Binlog To Kafka Java SDK Support

Language: Java - Size: 37.1 KB - Last synced: 17 days ago - Pushed: over 4 years ago - Stars: 0 - Forks: 1

php-enqueue/magento-enqueue

The extension adds messaging capabilities to Magento1 application.

Language: PHP - Size: 25.4 KB - Last synced: 17 days ago - Pushed: over 6 years ago - Stars: 24 - Forks: 8

phobos/phobos

Simplifying Kafka for ruby apps

Language: Ruby - Size: 6.35 MB - Last synced: 1 day ago - Pushed: 9 months ago - Stars: 219 - Forks: 38

kafbat/kafka-ui

Open-Source Web UI for managing Apache Kafka clusters

Language: Java - Size: 33.8 MB - Last synced: 18 days ago - Pushed: 18 days ago - Stars: 305 - Forks: 14

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: 299 KB - Last synced: 17 days ago - Pushed: 17 days ago - Stars: 1 - Forks: 0

sgerrand/alpine-pkg-kt

A Kafka tool that likes JSON, packaged for Alpine Linux

Language: Shell - Size: 1000 Bytes - Last synced: 18 days ago - Pushed: almost 6 years ago - Stars: 1 - Forks: 0

tulios/kafkajs

A modern Apache Kafka client for node.js

Language: JavaScript - Size: 11.6 MB - Last synced: 18 days ago - Pushed: 2 months ago - Stars: 3,594 - Forks: 500

fede1024/rust-rdkafka

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

Language: Rust - Size: 14.3 MB - Last synced: 19 days ago - Pushed: about 1 month ago - Stars: 1,481 - Forks: 251

nomisRev/kotlin-kafka

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

Language: Kotlin - Size: 2.24 MB - Last synced: 17 days ago - Pushed: 17 days ago - Stars: 95 - Forks: 11

ealeykin/aspnetcorekafka 📦

A messaging infrastructure on top of Confluent.Kafka and AspNetCore

Language: C# - Size: 358 KB - Last synced: 21 days ago - Pushed: almost 2 years ago - Stars: 21 - Forks: 5

tejasjadhav/nkafka

Kafka client for Nim

Language: Nim - Size: 74.2 KB - Last synced: 21 days ago - Pushed: about 2 years ago - Stars: 2 - 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: 19 days ago - Pushed: 25 days ago - Stars: 2,368 - Forks: 291

karafka/karafka

Ruby and Rails efficient Kafka processing framework

Language: Ruby - Size: 5.08 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 1,965 - Forks: 166

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: 14 days ago - Pushed: about 2 months ago - Stars: 7 - Forks: 2

hifly81/kafka-examples

Practical examples with Apache Kafka®

Language: Java - Size: 119 MB - Last synced: 24 days ago - Pushed: 24 days ago - Stars: 49 - Forks: 8

arnaud-lb/php-rdkafka

Production-ready, stable Kafka client for PHP

Language: C - Size: 880 KB - Last synced: 18 days ago - Pushed: 4 months ago - Stars: 2,035 - Forks: 263

aio-libs/aiokafka

asyncio client for kafka

Language: Python - Size: 3.22 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 1,042 - Forks: 214

stormaref/KafkaStorm

Simple .net client for Kafka based on Confluent.Kafka

Language: C# - Size: 56.6 KB - Last synced: 28 days ago - Pushed: 29 days ago - Stars: 3 - Forks: 0

FundingCircle/jackdaw

A Clojure library for the Apache Kafka distributed streaming platform.

Language: Clojure - Size: 1.83 MB - Last synced: 10 days ago - Pushed: 25 days ago - Stars: 368 - Forks: 81

pkazi/Dockerfiles

Dockerfiles for various simple docker images.

Language: Shell - Size: 10.7 KB - Last synced: about 1 month ago - Pushed: about 2 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: about 1 month ago - Pushed: about 1 month 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: 18 days ago - Pushed: 8 months ago - Stars: 56 - Forks: 10

Nasruddin/KafkaStarter

Kafka Starter with Java Client

Language: Java - Size: 2.93 KB - Last synced: about 1 month ago - Pushed: about 7 years ago - Stars: 1 - Forks: 0

sgerrand/alpine-pkg-kafkacat 📦

Kafkacat packaged for Alpine Linux

Size: 25.4 KB - Last synced: 18 days ago - Pushed: about 1 month ago - Stars: 10 - Forks: 2

Farfetch/kafkaflow

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

Language: C# - Size: 21.4 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 572 - Forks: 99

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.1 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 1,418 - Forks: 388

confluentinc/confluent-kafka-python

Confluent's Kafka Python Client

Language: Python - Size: 12 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 3,624 - Forks: 872

confluentinc/confluent-kafka-go

Confluent's Apache Kafka Golang client

Language: Go - Size: 297 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 4,409 - Forks: 642

confluentinc/confluent-kafka-dotnet

Confluent's Apache Kafka .NET client

Language: C# - Size: 4.07 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 2,729 - Forks: 836

taion809/transceiver

Kafka pub sub convenience

Language: Go - Size: 7.81 KB - Last synced: about 1 month ago - Pushed: almost 7 years ago - Stars: 0 - Forks: 0

provectus/kafka-ui

Open-Source Web UI for Apache Kafka Management

Language: Java - Size: 29 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 8,395 - Forks: 1,045

opentracing-contrib/java-specialagent

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

Language: Java - Size: 9.17 MB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 186 - Forks: 47

opentracing-contrib/java-kafka-client

OpenTracing Instrumentation for Apache Kafka Client

Language: Java - Size: 349 KB - Last synced: about 1 month ago - Pushed: 9 months ago - Stars: 124 - Forks: 65

danielwegener/logback-kafka-appender 📦

Logback appender for Apache Kafka

Language: Java - Size: 249 KB - Last synced: about 1 month ago - Pushed: almost 2 years ago - Stars: 631 - Forks: 261

dropwizard/dropwizard-kafka

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

Language: Java - Size: 437 KB - Last synced: 10 days ago - Pushed: about 1 month ago - Stars: 20 - Forks: 12

guoshiqiufeng/loki

Simplifying mq usage

Language: Java - Size: 607 KB - Last synced: 11 days ago - Pushed: about 1 month ago - Stars: 2 - Forks: 0

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: 563 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 139 - Forks: 46

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: about 2 months ago - Pushed: almost 6 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: about 1 month ago - Pushed: 2 months ago - Stars: 1 - Forks: 0

Tangtang1997/IKunLibrary

RabbitMQ、Kafka客户端库

Language: C# - Size: 56.6 KB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 3 - Forks: 0

Spinoco/fs2-kafka

Kafka client for functional streams for scala (fs2)

Language: Scala - Size: 260 KB - Last synced: about 2 months ago - Pushed: 10 months ago - Stars: 79 - Forks: 14

Trendyol/goncolos

Goncolos is simple wrapper top of confluent-kafka-dotnet

Language: C# - Size: 44.9 KB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 4 - Forks: 1

ciena/afkak

Kafka client written in Twisted Python

Language: Python - Size: 1.57 MB - Last synced: 16 days ago - Pushed: 9 months ago - Stars: 31 - Forks: 23

harshit-budhraja/kafka_handler

A simple Kafka wrapper based on confluent_kafka python client.

Language: Python - Size: 26.4 KB - Last synced: 16 days ago - Pushed: about 4 years ago - Stars: 2 - Forks: 0

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: 2 months ago - Pushed: 5 months ago - Stars: 814 - Forks: 301

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: 3 months ago - Pushed: 3 months ago - Stars: 0 - Forks: 0

Vijendra07Kulhade/kafkademoapp

Language: Java - Size: 6.84 KB - Last synced: 3 months ago - Pushed: almost 7 years ago - Stars: 0 - Forks: 0

openweb-nl/kafka-graphql-examples

A platform to test solutions for using Kafka with Graphql

Language: Clojure - Size: 46.1 MB - Last synced: 12 days ago - Pushed: almost 4 years ago - Stars: 59 - Forks: 10

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: 2 months ago - Pushed: 5 months ago - Stars: 282 - Forks: 114

oslabs-beta/kafkaSaur

Apache Kafka client for Deno

Language: TypeScript - Size: 2.37 MB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 45 - Forks: 5

heimuheimu/naiveasync

对 Kafka 生产者和消费者进行封装，提供实时报警和数据监控功能。

Language: Java - Size: 358 KB - Last synced: 4 months ago - Pushed: almost 2 years ago - Stars: 15 - Forks: 5

DongJu-Na/kafkaStudy

카프카 겉핧기

Language: Java - Size: 90.8 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 0 - Forks: 0

snmslavk/kafka-net-core

kafka .net core library

Language: C# - Size: 68.4 KB - Last synced: 9 days ago - Pushed: almost 5 years ago - Stars: 25 - Forks: 6

nodefluent/node-sinek

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

Language: TypeScript - Size: 1.17 MB - Last synced: about 2 hours ago - Pushed: over 1 year ago - Stars: 291 - Forks: 52

rishav24x7/kafka-demo-java

This repo contains codes related to creating a kafka project using maven

Language: Java - Size: 4.88 KB - Last synced: 5 months ago - Pushed: 5 months ago - Stars: 0 - Forks: 0

php-enqueue/rdkafka

[READ-ONLY] The Kafka Enqueue transport.

Language: PHP - Size: 134 KB - Last synced: about 7 hours ago - Pushed: about 2 months ago - Stars: 48 - Forks: 37

oslabs-beta/kalibrate

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

Language: TypeScript - Size: 6.37 MB - Last synced: about 1 month ago - Pushed: 11 months ago - Stars: 60 - Forks: 3

robipozzi/robipozzi-kafkastreams-wordcount

Kafka Streams sample WordCount project for Spring Boot

Language: Shell - Size: 122 KB - Last synced: 25 days ago - Pushed: 4 months ago - Stars: 0 - Forks: 0

shankar-modi/node-kafka-client

Language: JavaScript - Size: 1000 Bytes - Last synced: 6 months ago - Pushed: almost 7 years ago - Stars: 0 - Forks: 0

BSVN/Commons

Commons library

Language: C# - Size: 5.28 MB - Last synced: 3 days ago - Pushed: 4 days ago - Stars: 6 - Forks: 8

imiphp/imi-kafka

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

Language: PHP - Size: 245 KB - Last synced: about 20 hours ago - Pushed: 5 months ago - Stars: 3 - Forks: 0

thejasbabu/kafka-example

A simple Kafka Consumer and Producer example

Language: Java - Size: 9.77 KB - Last synced: 7 months ago - Pushed: about 6 years ago - Stars: 9 - Forks: 20

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: 6 months ago - Pushed: almost 4 years ago - Stars: 147 - Forks: 147

LearningJournal/ApacheKafkaTutorials

Example Code for Kafka Tutorials @ Learning Journal

Language: Java - Size: 20.5 KB - Last synced: 6 months ago - Pushed: over 6 years ago - Stars: 172 - Forks: 218

tmcgrath/kafka-examples

Wait for it.... Kafka Examples!

Language: Scala - Size: 10.7 KB - Last synced: 8 months ago - Pushed: over 4 years ago - Stars: 4 - Forks: 1

freakchick/kafkaUI-lite

史上最轻便好用的kafka 可视化图形界面客户端工具，可以生产消费消息，管理topic、group、集群。支持管理多个kafka环境。同时支持zookeeper redis 图形化界面操作

Language: Vue - Size: 1.27 MB - Last synced: 8 months ago - Pushed: 8 months ago - Stars: 71 - Forks: 24

madhawaudayakantha/kafka-react-app

This repositoty is for kafka-react-app to demonstrate Kafka Message Produce/Consume

Size: 312 KB - Last synced: 9 months ago - Pushed: 10 months ago - Stars: 0 - Forks: 0

amareshy/Kafka-client-examples

Demo application of Kafka client producer and consumer

Language: Java - Size: 29.3 MB - Last synced: 9 months ago - Pushed: almost 5 years ago - Stars: 0 - Forks: 0

the-code-experiments/get-to-know-kafka

Learn the basics of Kafka with different language implementations

Language: Java - Size: 6.84 KB - Last synced: 9 months ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0

squ1d123/kafka-ops-demo

This is to demontrate what we can use to automate kafka operations such as adding ACLs, Topics and Topic Configs.

Language: Shell - Size: 781 KB - Last synced: 9 months ago - Pushed: almost 4 years ago - Stars: 1 - Forks: 1

jaimedantas/kafka-service

Service based on event-driven

Language: Java - Size: 17.6 KB - Last synced: 9 months ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0

BAPostma/kafka-topic-acl-provisioner

Shell script that uses a CSV config file to create Topics in Kafka and set Access Control Lists on them

Language: Shell - Size: 1000 Bytes - Last synced: 10 months ago - Pushed: over 4 years ago - Stars: 1 - Forks: 0

santik/kafkatool

Tool to manage kafka topics

Language: Python - Size: 26.4 KB - Last synced: 10 months ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0

dselivanov/rscalaKafka 📦

Tiny R kafka client with rscala

Language: R - Size: 13.3 MB - Last synced: 10 months ago - Pushed: about 7 years ago - Stars: 10 - Forks: 3

danielgetset/reimagined-waffle

node

Language: Vue - Size: 741 KB - Last synced: 10 months ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

severstal-digital/wunderkafka

The power of librdkafka for pythons

Language: Python - Size: 306 KB - Last synced: 12 days ago - Pushed: 4 months ago - Stars: 3 - Forks: 1

telkomdev/kafka-cli

Kafka command line client written in Go

Language: Go - Size: 69.3 KB - Last synced: 9 months ago - Pushed: about 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: 10 months ago - Pushed: about 1 year ago - Stars: 7 - Forks: 0

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: 10 months ago - Pushed: about 3 years ago - Stars: 4 - Forks: 0

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: 3 months ago - Pushed: over 1 year ago - Stars: 54 - Forks: 17

RosarioB/kafka-clients

Kafka Clients in Java

Size: 26.4 MB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 0 - Forks: 0

tayeva/librdkafka-examples-cpp

Examples using librdkafka

Language: C++ - Size: 51.8 KB - Last synced: 10 months ago - Pushed: 11 months ago - Stars: 0 - Forks: 0