confluentinc/librdkafka

The Apache Kafka C/C++ library

Language: C - Size: 30.6 MB - Last synced: 14 days ago - Pushed: 15 days ago - Stars: 7,297 - Forks: 3,109

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

qunarcorp/qmq

QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景； 也包括报价搜索等高吞吐量场景。

Language: Java - Size: 6.92 MB - Last synced: about 1 month ago - Pushed: 6 months ago - Stars: 2,774 - Forks: 692

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

php-amqplib/RabbitMqBundle

RabbitMQ Bundle for the Symfony web framework

Language: PHP - Size: 960 KB - Last synced: 9 days ago - Pushed: about 2 months ago - Stars: 1,218 - Forks: 469

authorjapps/zerocode

A community-developed, free, opensource, automated testing framework for microservices APIs, Kafka(Data Streams) and Load testing. Zerocode Open Source enables you to create, change and maintain your automated test scenarios via simple JSON or YAML files. Visit documentation below:

Language: Java - Size: 4.78 MB - Last synced: 3 days ago - Pushed: 12 days ago - Stars: 853 - Forks: 367

areed1192/td-ameritrade-python-api

Unofficial Python API client library for TD Ameritrade. This library allows for easy access of the Standard API and allows users to build data pipelines for the Streaming API.

Language: Python - Size: 2 MB - Last synced: 18 days ago - Pushed: 12 months ago - Stars: 683 - Forks: 254

bsm/sarama-cluster 📦

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]

Language: Go - Size: 331 KB - Last synced: 3 months ago - Pushed: over 4 years ago - Stars: 1,007 - Forks: 224

pact-foundation/pact_broker

Enables your consumer driven contracts workflow

Language: Ruby - Size: 11.2 MB - Last synced: about 1 month ago - Pushed: about 2 months ago - Stars: 693 - Forks: 172

redpanda-data/kminion

KMinion is a feature-rich Prometheus exporter for Apache Kafka written in Go. It is lightweight and highly configurable so that it will meet your requirements.

Language: Go - Size: 8.14 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 569 - Forks: 122

ddo/oauth-1.0a

OAuth 1.0a Request Authorization for Node and Browser

Language: JavaScript - Size: 262 KB - Last synced: 9 days ago - Pushed: 6 months ago - Stars: 322 - Forks: 118

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

Qihoo360/qbusbridge

The Apache Kafka Client SDK

Language: C++ - Size: 701 KB - Last synced: 27 days ago - Pushed: 3 months ago - Stars: 289 - Forks: 72

swarrot/SwarrotBundle

A symfony bundle for swarrot integration

Language: PHP - Size: 358 KB - Last synced: about 1 month ago - Pushed: 5 months ago - Stars: 90 - Forks: 59

hyeonsangjeon/youtube-dl-nas

youtube download queue websocket server with login for private NAS.

Language: Python - Size: 651 KB - Last synced: 28 days ago - Pushed: 12 months ago - Stars: 151 - Forks: 55

mre/kafka-influxdb

High performance Kafka consumer for InfluxDB. Supports collectd message formats.

Language: Python - Size: 1.56 MB - Last synced: 18 days ago - Pushed: over 1 year ago - Stars: 215 - Forks: 54

robinjoseph08/redisqueue

redisqueue provides a producer and consumer of a queue that uses Redis streams

Language: Go - Size: 32.2 KB - Last synced: 19 days ago - Pushed: 2 months ago - Stars: 122 - Forks: 54

nodefluent/node-sinek

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

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

spider-123-eng/Spark

Apache Spark is a fast, in-memory data processing engine with elegant and expressive development API's to allow data workers to efficiently execute streaming, machine learning or SQL workloads that require fast iterative access to datasets.This project will have sample programs for Spark in Scala language .

Language: Scala - Size: 6.59 MB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 55 - Forks: 42

ohbus/retail-banking

Consumer Banking Application

Language: Java - Size: 647 KB - Last synced: 7 months ago - Pushed: over 1 year ago - Stars: 34 - Forks: 41

silviucpp/erlkaf

Erlang kafka driver based on librdkafka

Language: Erlang - Size: 233 KB - Last synced: 26 days ago - Pushed: 26 days ago - Stars: 81 - Forks: 39

davidmarquis/redisq

RedisQ - Java implementation of a reliable Pub/Sub message queue based on Redis

Language: Java - Size: 55.7 KB - Last synced: about 1 month ago - Pushed: over 6 years ago - Stars: 99 - Forks: 36

gnuhpc/Kafka-zk-restapi

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

Language: Java - Size: 13.8 MB - Last synced: 6 months ago - Pushed: over 1 year ago - Stars: 124 - Forks: 33

mikemadisonweb/yii2-rabbitmq

RabbitMQ Extension for Yii2

Language: PHP - Size: 184 KB - Last synced: 2 months ago - Pushed: about 1 year ago - Stars: 72 - Forks: 31

yidas/codeigniter-queue-worker

CodeIgniter 3 Daemon Queue Worker (Consumer) Management Controller

Language: PHP - Size: 99.6 KB - Last synced: 2 days ago - Pushed: 12 months ago - Stars: 89 - Forks: 31

zalando-incubator/remora

Kafka consumer lag-checking application for monitoring, written in Scala and Akka HTTP; a wrap around the Kafka consumer group command. Integrations with Cloudwatch and Datadog. Authentication recently added

Language: Scala - Size: 157 KB - Last synced: about 2 months ago - Pushed: over 1 year ago - Stars: 197 - Forks: 31

CashlessConsumer/CashlessConsumer 📦

CashlessConsumer

Language: HTML - Size: 9.39 MB - Last synced: about 1 year ago - Pushed: over 7 years ago - Stars: 13 - Forks: 29

davidcampos/kafka-spark-flink-example

Kafka streaming with Spark and Flink example

Language: Java - Size: 15.6 KB - Last synced: 2 months ago - Pushed: 10 months ago - Stars: 26 - Forks: 25

GokGokalp/MetroBus

Lightweight messaging wrapper of MassTransit

Language: C# - Size: 69.3 KB - Last synced: 21 days ago - Pushed: over 3 years ago - Stars: 72 - Forks: 22

javibravo/simpleue

PHP queue worker and consumer - Ready for AWS SQS, Redis, Beanstalkd and others.

Language: PHP - Size: 87.9 KB - Last synced: 29 days ago - Pushed: over 6 years ago - Stars: 128 - Forks: 22

lifion/lifion-kinesis

A native Node.js producer and consumer library for Amazon Kinesis Data Streams

Language: JavaScript - Size: 4.04 MB - Last synced: 11 days ago - Pushed: 10 months ago - Stars: 86 - Forks: 18

gmr/rejected

rejected is a consumer framework for RabbitMQ

Language: Python - Size: 1.18 MB - Last synced: 18 days ago - Pushed: 2 months ago - Stars: 58 - Forks: 18

openware/postmaster

Notification Hub for openware stack

Language: Go - Size: 131 KB - Last synced: 9 days ago - Pushed: over 4 years ago - Stars: 14 - Forks: 18

authorjapps/hello-kafka-stream-testing

The most simple way to test Kafka based applications or micro-services e.g. Read/Write during HBase/Hadoop or other Data Ingestion Pipe Lines

Language: Java - Size: 62.5 KB - Last synced: 30 days ago - Pushed: over 3 years ago - Stars: 26 - Forks: 18

qianguozheng/go-workerpool

Worker pool implementation

Language: Go - Size: 3.91 KB - Last synced: about 1 year ago - Pushed: over 5 years ago - Stars: 72 - Forks: 17

oslabs-beta/AtomicKafka

Language: JavaScript - Size: 949 KB - Last synced: 15 days ago - Pushed: over 1 year ago - Stars: 107 - Forks: 16

makasim/amqpextra

Golang AMQP reliable connection, publisher, consumer.

Language: Go - Size: 299 KB - Last synced: 9 months ago - Pushed: over 1 year ago - Stars: 70 - Forks: 16

repository-service-tuf/repository-service-tuf-worker

Repository Service for TUF: Worker

Language: Python - Size: 2.36 MB - Last synced: 27 days ago - Pushed: 27 days ago - Stars: 9 - Forks: 15

sevennt/rocketmq Fork of didapinchegit/go_rocket_mq

RocketMQ client for go supportting producer and consumer.

Language: Go - Size: 139 KB - Last synced: about 1 month ago - Pushed: almost 6 years ago - Stars: 29 - Forks: 15

cevio/dubbo.ts

阿里巴巴 dubbo 协议的NodeJS版实现：一套完整的从Provider到consumer的解决方案，高性能支持高QPS。

Language: TypeScript - Size: 336 KB - Last synced: 13 days ago - Pushed: over 3 years ago - Stars: 135 - Forks: 14

foobaar/kafka-offset-manager

Move Consumer offsets as you please

Language: Kotlin - Size: 74.2 KB - Last synced: 9 months ago - Pushed: over 6 years ago - Stars: 8 - Forks: 12

quantmind/pulsar-queue 📦

Asynchronous message queue consumer and scheduler

Language: Python - Size: 863 KB - Last synced: about 1 month ago - Pushed: over 6 years ago - Stars: 62 - Forks: 11

roadrunner-php/jobs

:electric_plug: RoadRunner Jobs (Queue) SDK

Language: PHP - Size: 232 KB - Last synced: 8 days ago - Pushed: about 1 month ago - Stars: 20 - Forks: 10

seaswalker/Consumer

封装常用的生产者-消费者模型

Language: Java - Size: 88.9 KB - Last synced: about 1 year ago - Pushed: about 7 years ago - Stars: 17 - Forks: 10

Gurenax/node-rabbitmq

🐰 A guide for RabbitMQ basic patterns in 30 steps

Language: JavaScript - Size: 307 KB - Last synced: about 1 year ago - Pushed: about 6 years ago - Stars: 31 - Forks: 10

triffic-tang/AnotherKafkaMonitor-AKM-

Another app which used to monitor the progress of Kafka Producer and Consumer

Language: Java - Size: 47.8 MB - Last synced: about 1 year ago - Pushed: almost 4 years ago - Stars: 33 - Forks: 10

ng-turkey/ngx-context

Angular Context: Easy property binding for router outlet and nested component trees.

Language: TypeScript - Size: 1.97 MB - Last synced: 16 days ago - Pushed: over 1 year ago - Stars: 134 - Forks: 9

andrewinci/Insulator 📦

A client UI to inspect Kafka topics, consume, produce and much more

Language: Kotlin - Size: 29.6 MB - Last synced: about 1 month ago - Pushed: about 1 year ago - Stars: 57 - Forks: 9

lirantal/awesome-contract-testing

Awesome resources for Consumer-Driven Contract Testing

Size: 10.7 KB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 73 - Forks: 9

jobcloud/php-kafka-lib

PHP Kafka producer / consumer library with PHP Avro support, based on php-rdkafka

Language: PHP - Size: 188 KB - Last synced: 17 days ago - Pushed: 6 months ago - Stars: 52 - Forks: 9

ConsumerDataStandardsAustralia/standards-maintenance

This repository houses the interactions, consultations and work management to support the maintenance of baselined components of the Consumer Data Right API Standards and Information Security profile.

Language: HTML - Size: 388 KB - Last synced: 26 days ago - Pushed: 26 days ago - Stars: 41 - Forks: 9

ayeo-flex-org/pulsar-flex

Pulsar Flex is a modern Apache Pulsar client for Node.js, developed to be independent of C++.

Language: JavaScript - Size: 439 KB - Last synced: 12 days ago - Pushed: about 1 year ago - Stars: 44 - Forks: 9

sspathak/VoiceChat

a Python voice chat app that uses WebSockets to send encrypted data between a multi-threaded client and server

Language: Python - Size: 18.6 MB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 39 - Forks: 8

flolu/kafka

Realtime BTC and ETH Wallet Tracker with Node.js and Kafka

Language: TypeScript - Size: 290 KB - Last synced: 18 days ago - Pushed: over 1 year ago - Stars: 15 - Forks: 8

domwood/kiwi-kafka

kiwi-kafka - A Kafka Web Interface

Language: Java - Size: 3.95 MB - Last synced: 17 days ago - Pushed: 18 days ago - Stars: 12 - Forks: 7

first-digital-finance/pyrmq

Python with RabbitMQ—simplified so you won't have to.

Language: Python - Size: 129 KB - Last synced: 9 days ago - Pushed: 9 days ago - Stars: 18 - Forks: 7

doubaokun/metaq-php

MetaQ PHP client library

Language: PHP - Size: 122 KB - Last synced: about 1 month ago - Pushed: over 10 years ago - Stars: 38 - Forks: 7

annu12340/Choose-Smart

As consumers, we face a great dilemma in choosing the right product from a wide variety of goods. Choose Smart is an application that helps the user to analyze the product and arrive at a smarter choice.

Language: HTML - Size: 141 KB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 5 - Forks: 7

d-ulyanov/kafka-sniffer

TCP traffic analyzer that can capture requests from clients to Kafka Broker, parse them and expose stats like client IPs as Prometheus metrics.

Language: Go - Size: 110 KB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 7 - Forks: 6

dial-once/node-bunnymq

BunnyMQ is an amqp.node wrapper to ease common AMQP usages (RPC, pub/sub, channel/connection handling etc.).

Language: JavaScript - Size: 1.57 MB - Last synced: 12 days ago - Pushed: about 5 years ago - Stars: 19 - Forks: 6

tusharnankani/Swadeshi

Implementing a Web Based solution through which farmers can participate in a commodity exchange market

Language: JavaScript - Size: 22.1 MB - Last synced: 18 days ago - Pushed: about 1 year ago - Stars: 21 - Forks: 6

php-kafka/php-simple-kafka-client

PHP Kafka extension, supports also Redpanda

Language: C - Size: 169 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 20 - Forks: 6

lifeofcoder/async-task

基于Disruptor的异步任务执行框架。支持本地异步任务场景的快速开发。同时确保任务100%执行成功。

Language: Java - Size: 56.6 KB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 4 - Forks: 6

Abdulsametileri/cdc-pact-gophercon-2021

How to write CDC test using Pact in Go? 🤔

Language: Go - Size: 837 KB - Last synced: 2 months ago - Pushed: over 2 years ago - Stars: 53 - Forks: 6

tgrall/redis-streams-in-action

Project that shows how to use ADD/ACK/PENDING/CLAIM and build an error proof streaming application with Redis Streams and SpringData

Language: Java - Size: 3.15 MB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 4 - Forks: 5

ThiagoBarradas/queue-consumer

A simple consumer for Rabbit MQ sending a post with basic auth and all structure for retry and dead queue.

Language: C# - Size: 81.1 KB - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 6 - Forks: 5

1995parham/saf

Using NATS Jetstream as queue manager to replace RabbitMQ, etc.

Language: Go - Size: 651 KB - Last synced: 6 days ago - Pushed: 6 days ago - Stars: 27 - Forks: 5

weiboad/aidp 📦

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

Language: C++ - Size: 144 KB - Last synced: about 2 months ago - Pushed: over 6 years ago - Stars: 20 - Forks: 5

skroutz/rafka-rb

Ruby client library for Rafka

Language: Ruby - Size: 137 KB - Last synced: 14 days ago - Pushed: over 4 years ago - Stars: 8 - Forks: 5

findmypast-oss/jackal 📦

Consumer Driven Contracts Microservice

Language: JavaScript - Size: 1.2 MB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 25 - Forks: 5

makerlee/spring-kafka-demo

spring-kakfa 多线程消费代码提交

Language: Java - Size: 5.86 KB - Last synced: about 1 year ago - Pushed: over 6 years ago - Stars: 7 - Forks: 5

qntfy/frizzle

The magic message bus

Language: Go - Size: 34.2 KB - Last synced: about 2 months ago - Pushed: about 5 years ago - Stars: 15 - Forks: 4

lmajano/messaging-polyglot

RabbitMQ Messaging Polyglot with Java, ColdFusion, CommandBox, Groovy and more

Language: ColdFusion - Size: 4.8 MB - Last synced: 12 months ago - Pushed: 12 months ago - Stars: 18 - Forks: 4

qntfy/frafka

Frizzle for Apache Kafka

Language: Go - Size: 53.7 KB - Last synced: about 2 months ago - Pushed: over 3 years ago - Stars: 13 - Forks: 4

calvinlfer/Kafka-Akka-HTTP-and-Akka-Streams-integration

An example showing how to integrate Apache Kafka with Akka Streams and Akka HTTP.

Language: Scala - Size: 4.88 KB - Last synced: 12 months ago - Pushed: over 7 years ago - Stars: 15 - Forks: 4

confluentinc/confluent-kafka-javascript

Confluent's Apache Kafka JavaScript client

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

sichkar-valentyn/Transportation_Problem

Transportation Model for an optimal strategy for distributing a commodity from a group of supply centers to various receiving centers. Solved in C# Windows Form Application

Language: C# - Size: 732 KB - Last synced: 4 months ago - Pushed: almost 5 years ago - Stars: 12 - Forks: 4

mvallim/spring-schema-registry

The purpose of this module is to solve the problem of multiple keystores using Spring Boot + Kafka + Schema Registry + SSL and Spring Schema Resgistry Test

Language: Java - Size: 299 KB - Last synced: about 1 month ago - Pushed: 11 months ago - Stars: 28 - Forks: 4

anicetkeric/spring-apache-pulsar

https://boottechnologies-ci.medium.com/apache-pulsar-consumer-and-producer-with-spring-boot-916fd06f669

Language: Java - Size: 68.4 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 2 - Forks: 4

hcanfly/solitaire_flutter

Solitaire is a version of the game written for Flutter in Dart. Updated to Flutter 2.5.3, Dart 2.14.4 with Null Safety, etc. Also updated app to use Providers with ChangeNotifier and Consumer.

Language: Dart - Size: 1.14 MB - Last synced: 2 months ago - Pushed: over 2 years ago - Stars: 3 - Forks: 4

social9/go-queues

A scalable and generic producer-consumer service written in Go

Language: Go - Size: 38.1 KB - Last synced: 10 months ago - Pushed: over 3 years ago - Stars: 1 - Forks: 4

calebboyd/redis-x-stream

An AsyncIterable interface for reading redis streams

Language: TypeScript - Size: 1.67 MB - Last synced: 10 days ago - Pushed: 10 months ago - Stars: 8 - Forks: 4

omarathon/oauth1-hmac

OAuth1.0 Consumer Library.

Language: Java - Size: 269 KB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 7 - Forks: 4

harshitkathuria/FoodTime

FoodTime - MERN Stack application

Language: JavaScript - Size: 2.6 MB - Last synced: about 1 year ago - Pushed: almost 3 years ago - Stars: 17 - Forks: 4

rahmanidashti/CPFairRecSys

[Official Codes] CPFair: Personalized Consumer and Producer Fairness Re-ranking for Recommender Systems (SIGIR2022)

Language: Jupyter Notebook - Size: 37.9 MB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 7 - Forks: 4

facile-it/rabbitmq-consumer

A configurable RabbitMQ consumer made in Rust, useful for a stable and reliable CLI commands processor.

Language: Rust - Size: 201 KB - Last synced: about 2 months ago - Pushed: almost 3 years ago - Stars: 27 - Forks: 3

Wisembly/AMQPBundle 📦

AMQPBundle built on top of Symfony 2 and Swarrot

Language: PHP - Size: 213 KB - Last synced: about 2 months ago - Pushed: almost 6 years ago - Stars: 3 - Forks: 3

datanerds-io/verteiler

Meine dispatcher says there's something wrong mit deine Kabel. Java 8 BlockingQueue Kafka Consumer with automatically maintained offset.

Language: Java - Size: 32.2 KB - Last synced: 11 months ago - Pushed: almost 6 years ago - Stars: 7 - Forks: 3

BBC-Data-Unit/christmas-dinner

Is Christmas getting cheaper, or more expensive?

Size: 323 KB - Last synced: 10 months ago - Pushed: over 7 years ago - Stars: 2 - Forks: 3

microlinkhq/queue

The high resilient queue for processing URLs.

Language: JavaScript - Size: 124 KB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 10 - Forks: 3

ferpetrelli/eloquent-consumer

API consumer and query builder with an Eloquent like syntax

Language: PHP - Size: 34.2 KB - Last synced: about 1 month ago - Pushed: over 5 years ago - Stars: 6 - Forks: 3

tolitius/grete

kafka client with threads and a scheduler

Language: Clojure - Size: 43.9 KB - Last synced: 11 days ago - Pushed: 6 months ago - Stars: 16 - Forks: 3

Sanji515/Hackfest19

Language: CSS - Size: 4.38 MB - Last synced: about 1 year ago - Pushed: about 5 years ago - Stars: 2 - Forks: 3

wkennedy/spring-kafka-cloud-events

The spring-kafka-cloud-events library provides utility in order to use the CloudEvents spec in your project that uses Spring-Kafka.

Language: Java - Size: 45.9 KB - Last synced: about 1 month ago - Pushed: over 3 years ago - Stars: 5 - Forks: 3

onetransistor/MediaKeyboard

STM32 Arduino Library with support for USB consumer control device (media keys)

Language: C - Size: 33.2 KB - Last synced: 5 months ago - Pushed: almost 4 years ago - Stars: 13 - Forks: 3

vivekascoder/rimoto

Control your computer with your phone.

Language: Python - Size: 171 KB - Last synced: about 1 year ago - Pushed: almost 3 years ago - Stars: 10 - Forks: 3

websublime/kong-console 📦

Angular 2 UI console for getkong.org

Language: CSS - Size: 6.26 MB - Last synced: about 2 months ago - Pushed: over 7 years ago - Stars: 13 - Forks: 3

Nefari0uss/producer-consumer

Producer & Consumer simulation to experiment and learn threading.

Language: C - Size: 8.79 KB - Last synced: 7 months ago - Pushed: over 7 years ago - Stars: 3 - Forks: 3

jkone27/AliceMQ

A reactive client library for RabbitMQ and Google PubSub, with observables, acknowledge and reject capabilities

Language: C# - Size: 625 KB - Last synced: about 2 months ago - Pushed: 2 months ago - Stars: 5 - Forks: 2

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: 10 months ago - Pushed: almost 3 years ago - Stars: 11 - Forks: 2