GitHub topics: consumer
1995parham/saf
Using NATS Jetstream as queue manager to replace RabbitMQ, etc.
Language: Go - Size: 728 KB - Last synced at: about 5 hours ago - Pushed at: about 5 hours ago - Stars: 32 - Forks: 3
silviucpp/erlkaf
Erlang kafka driver based on librdkafka
Language: Erlang - Size: 224 KB - Last synced at: about 17 hours ago - Pushed at: about 17 hours ago - Stars: 86 - Forks: 43
confluentinc/librdkafka
The Apache Kafka C/C++ library
Language: C - Size: 34.2 MB - Last synced at: 1 day ago - Pushed at: 2 days ago - Stars: 577 - Forks: 3,193
ChiefGokhlayeh/tap-consooomer
📦 Test Anything Protocol Consumer for Rust
Language: Rust - Size: 316 KB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 3 - Forks: 0
soenneker/soenneker.blazor.consumer
A derivative of Soenneker.Blazor.Consumer.Base, providing instance-wide generic type setting.
Language: C# - Size: 1.15 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 1 - Forks: 0
soenneker/soenneker.blazor.consumers.base
A wrapper around Soenneker.Blazor.ApiClient supporting auto (de)serialization for requests/responses/ProblemDetails.
Language: C# - Size: 106 KB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 0 - Forks: 0
repository-service-tuf/repository-service-tuf-worker
Repository Service for TUF: Worker
Language: Python - Size: 3.34 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 8 - Forks: 16
soenneker/soenneker.blazor.consumers.core
A class that represents the core Blazor Consumer, providing no additional functionality than access to Soenneker.Blazor.ApiClient
Language: C# - Size: 111 KB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 0 - Forks: 0
AndriyKalashnykov/go-kafka-confluent-examples
Confluent Cloud Kafka examples in Go
Language: Shell - Size: 381 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 1 - Forks: 0
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.19 MB - Last synced at: about 17 hours ago - Pushed at: 8 days ago - Stars: 656 - Forks: 129
confluentinc/confluent-kafka-javascript
Confluent's Apache Kafka JavaScript client
Language: JavaScript - Size: 5.42 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 155 - Forks: 14
confluentinc/confluent-kafka-go
Confluent's Apache Kafka Golang client
Language: HTML - Size: 497 MB - Last synced at: 1 day ago - Pushed at: 2 days ago - Stars: 4,828 - Forks: 678
Farfetch/kafkaflow
Apache Kafka .NET Framework to create applications simple to use and extend.
Language: C# - Size: 23.4 MB - Last synced at: 3 days ago - Pushed at: 5 days ago - Stars: 716 - Forks: 124
pact-foundation/pact_broker
Enables your consumer driven contracts workflow
Language: Ruby - Size: 11.9 MB - Last synced at: 2 days ago - Pushed at: 4 days ago - Stars: 717 - Forks: 181
IQKV/quickstart-amqp-consuming-hello
Minimal Spring Boot based sample of AMQP consumer app.
Language: Java - Size: 289 KB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 1 - Forks: 1
segmentio/kafka-go
Kafka library in Go
Language: Go - Size: 2.13 MB - Last synced at: 8 days ago - Pushed at: 11 days ago - Stars: 7,898 - Forks: 802
linkmodo/NLP
Classifier/recommender based on consumer complaint
Language: Python - Size: 1.73 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 0 - Forks: 0
pagarme/sqs-quooler 📦
A complete queue consumer for SQS
Language: JavaScript - Size: 164 KB - Last synced at: 7 days ago - Pushed at: 7 months ago - Stars: 1 - Forks: 0
php-amqplib/RabbitMqBundle
RabbitMQ Bundle for the Symfony web framework
Language: PHP - Size: 970 KB - Last synced at: 4 days ago - Pushed at: 3 months ago - Stars: 1,231 - Forks: 468
iqkv/quickstart-kafka-consuming-hello
Minimal Spring Boot based sample of Kafka consumer app.
Language: Java - Size: 309 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 0 - Forks: 0
qunarcorp/qmq
QMQ是去哪儿网内部广泛使用的消息中间件，自2012年诞生以来在去哪儿网所有业务场景中广泛的应用，包括跟交易息息相关的订单场景； 也包括报价搜索等高吞吐量场景。
Language: Java - Size: 6.92 MB - Last synced at: 9 days ago - Pushed at: over 1 year ago - Stars: 2,813 - Forks: 705
hendisantika/kafka-producer-consumer-upstash
Kafka Producer Consumer Upstash
Language: Java - Size: 702 KB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 3 - Forks: 0
jorgermduarte/poc-s3-kinesis-opensearch
Language: JavaScript - Size: 231 KB - Last synced at: 9 days ago - Pushed at: 12 days ago - Stars: 0 - Forks: 0
nodef/extra-queue
Collection of elements where insert, delete happens only at the ends.
Language: JavaScript - Size: 7.81 KB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 0 - Forks: 0
eharrow/amq-queue-drainer-ts
Drain AMQP message queues
Language: TypeScript - Size: 2.78 MB - Last synced at: 14 days ago - Pushed at: 14 days ago - Stars: 1 - Forks: 0
jorgermduarte/poc-csharp-kafka-project
Language: C# - Size: 230 KB - Last synced at: 4 days ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0
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 at: 14 days ago - Pushed at: almost 2 years ago - Stars: 680 - Forks: 250
microlinkhq/queue
The high resilient queue for processing URLs.
Language: JavaScript - Size: 117 KB - Last synced at: 14 days ago - Pushed at: 9 months ago - Stars: 13 - Forks: 4
authorjapps/zerocode
A community-developed, free, opensource, automated testing framework for microservices APIs, Kafka(Data Streams), Databases and Load testing. Zerocode Open Source enables you to create, change and maintain your automated test scenarios via simple JSON or YAML files—no coding required.
Language: Java - Size: 4.69 MB - Last synced at: 6 days ago - Pushed at: 13 days ago - Stars: 934 - Forks: 414
bsm/sarama-cluster 📦
Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]
Language: Go - Size: 331 KB - Last synced at: 3 days ago - Pushed at: over 5 years ago - Stars: 1,007 - Forks: 223
samber/go-amqp-pubsub
Fault tolerant Pub/Sub library for RabbitMQ
Language: Go - Size: 633 KB - Last synced at: 1 day ago - Pushed at: 19 days ago - Stars: 23 - Forks: 0
soenneker/soenneker.blazor.consumer.base
An abstract wrapper around Soenneker.Blazor.ApiClient supporting auto (de)serialization for requests/responses/ProblemDetails.
Language: C# - Size: 989 KB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 0 - Forks: 0
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 at: 11 days ago - Pushed at: about 2 years ago - Stars: 25 - Forks: 6
nimbly/Syndicate
A powerful queue and pubsub message publisher and consumer framework.
Language: PHP - Size: 356 KB - Last synced at: 18 days ago - Pushed at: 26 days ago - Stars: 28 - Forks: 0
justtrackio/terraform-aws-ecs-alarm-consumer
Language: HCL - Size: 87.9 KB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 0 - Forks: 0
k1729p/Miscellany
Language: Java - Size: 6.17 MB - Last synced at: 28 days ago - Pushed at: 28 days ago - Stars: 0 - Forks: 0
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: 442 KB - Last synced at: 2 days ago - Pushed at: 4 months ago - Stars: 48 - Forks: 9
event-band/band-symfony-bundle
Symfony2 Bundle for EventBand
Language: PHP - Size: 149 KB - Last synced at: 11 days ago - Pushed at: about 1 month ago - Stars: 8 - Forks: 0
davidmarquis/redisq
RedisQ - Java implementation of a reliable Pub/Sub message queue based on Redis
Language: Java - Size: 55.7 KB - Last synced at: 22 days ago - Pushed at: over 7 years ago - Stars: 107 - Forks: 37
flolu/kafka
Realtime BTC and ETH Wallet Tracker with Node.js and Kafka
Language: TypeScript - Size: 290 KB - Last synced at: 17 days ago - Pushed at: over 2 years ago - Stars: 25 - Forks: 13
smok-serwis/coolamqp
Pure Python pretty fast AMQP client with sane reconnects for RabbitMQ 3/4
Language: Python - Size: 1.09 MB - Last synced at: 19 days ago - Pushed at: 5 months ago - Stars: 7 - Forks: 1
samuelmsilva2v/apiNotificacoes
API RESTful responsável por consumir dados e enviar mensagens ao usuário.
Language: Java - Size: 17.6 KB - Last synced at: 17 days ago - Pushed at: 4 months ago - Stars: 1 - Forks: 0
medfreeman/node-reddit-api-example 📦
Extract data fields from subreddit posts in node.js
Language: JavaScript - Size: 67.4 KB - Last synced at: 13 days ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 0
robinjoseph08/redisqueue
redisqueue provides a producer and consumer of a queue that uses Redis streams
Language: Go - Size: 32.2 KB - Last synced at: 15 days ago - Pushed at: about 1 year ago - Stars: 132 - Forks: 57
lirantal/awesome-contract-testing
Awesome resources for Consumer-Driven Contract Testing
Size: 10.7 KB - Last synced at: 7 days ago - Pushed at: over 2 years ago - Stars: 80 - Forks: 9
igarbayo/Producer-Consumer-Mutex
Tercer proyecto para la asignatura de Sistemas Operativos II
Language: C - Size: 41 KB - Last synced at: 20 days ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0
hyeonsangjeon/youtube-dl-nas
youtube download queue websocket server with login for private NAS.
Language: Python - Size: 651 KB - Last synced at: 14 days ago - Pushed at: almost 2 years ago - Stars: 158 - Forks: 53
2KAbhishek/pact-order-test
Contract Based Tests with Pact 🧪✅
Language: JavaScript - Size: 545 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0
2KAbhishek/recrud
CRUD React Consumer 🍦🌐
Language: JavaScript - Size: 680 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 2 - Forks: 0
Rupakpoddar/ConsumerKeyboard Fork of Truth129/ConsumerKeyboard
Extends the Arduino HID library to support consumer device keys.
Language: C++ - Size: 17.6 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0
MatheusABA/microservices_java_email
Microservices App for email using Java Spring Boot, Spring Web, Spring AMQP( RabbitMQ), JPA and PostgreSQL
Language: Java - Size: 11.7 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0
Ametion/Dyffi-Bus
A asynchronous pub/sub system built with custom in-memory broker and an FastAPI .
Language: Python - Size: 9.77 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0
lykmapipo/cap-consumer
Common Alert Protocol consumer
Language: JavaScript - Size: 4.29 MB - Last synced at: 18 days ago - Pushed at: about 2 years ago - Stars: 11 - Forks: 3
ddo/oauth-1.0a
OAuth 1.0a Request Authorization for Node and Browser
Language: JavaScript - Size: 262 KB - Last synced at: 7 days ago - Pushed at: over 1 year ago - Stars: 324 - Forks: 115
SelimHorri/project-tracking-system-web-frontend-app
project-tracking-system frontend Angular application
Language: TypeScript - Size: 276 KB - Last synced at: 9 days ago - Pushed at: over 3 years ago - Stars: 8 - Forks: 2
ibrahimsezer/Seezme
Seezme is a feature-rich voice and chat messaging application developed in Flutter. It provides seamless and real-time communication capabilities with a user-friendly interface, allowing users to stay connected via voice messages and chat. The project is built using the Provider package for state management.
Language: Dart - Size: 2.78 MB - Last synced at: 11 days ago - Pushed at: 4 months ago - Stars: 10 - Forks: 0
seaswalker/Consumer
封装常用的生产者-消费者模型
Language: Java - Size: 88.9 KB - Last synced at: 9 days ago - Pushed at: almost 8 years ago - Stars: 19 - Forks: 10
conorheffron/rabbitmq-tester
Tool for testing RabbitMQ instance.
Language: Java - Size: 58.6 KB - Last synced at: 5 days ago - Pushed at: about 2 months ago - Stars: 2 - Forks: 0
EmanAhmed55/Weather-Forecaster
A simple project of kafka and python to demonstrate basic concepts of producer, consumer and topic
Language: Python - Size: 11.7 KB - Last synced at: about 1 month ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0
denisecase/buzzline-05-case
Kafka pipelines with data storage
Language: Python - Size: 31.3 KB - Last synced at: 10 days ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 30
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 at: 11 days ago - Pushed at: about 6 years ago - Stars: 19 - Forks: 6
joegasewicz/forestmq
Message queue 🌲
Language: C - Size: 366 KB - Last synced at: 11 days ago - Pushed at: 2 months ago - Stars: 9 - Forks: 0
phillipjhl/white_rabbit
Elixir library that uses the AMQP to provide behaviors that dynamically supervises all connections, channels, consuming, producing, and exchanging of RabbitMQ messages. Also provides an api to send RPC messages to other distributed elixir nodes via reply_to queues.
Language: Elixir - Size: 894 KB - Last synced at: 2 days ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 0
openware/postmaster
Notification Hub for openware stack
Language: Go - Size: 131 KB - Last synced at: 6 days ago - Pushed at: over 5 years ago - Stars: 15 - Forks: 18
wookieb/alpha-amqp-consumer
Reliable message consumption via AMQP protocol
Language: TypeScript - Size: 202 KB - Last synced at: 15 days ago - Pushed at: about 3 years ago - Stars: 3 - Forks: 0
lee-lou2/aws-ses-sender-go
[Golang] AWS SES Sender
Language: Go - Size: 154 KB - Last synced at: 17 days ago - Pushed at: 2 months ago - Stars: 16 - Forks: 5
quantmind/pulsar-queue 📦
Asynchronous message queue consumer and scheduler
Language: Python - Size: 863 KB - Last synced at: 1 day ago - Pushed at: over 7 years ago - Stars: 59 - Forks: 11
DemoStephen/Ubuntu-Mart
UbuntuMart embraces the Caregiver archetype, focusing on nurturing, supporting, and improving the well-being of the community. The brand reflects compassion and the desire to help others prosper through shared commerce and cooperation
Language: JavaScript - Size: 6.79 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0
KhadijaAbdeLouassaa/chat-application
chat-application
Language: Python - Size: 144 KB - Last synced at: 15 days ago - Pushed at: 4 months ago - Stars: 2 - Forks: 0
pirj/awesome-timesavers
Time savers
Size: 1000 Bytes - Last synced at: 2 days ago - Pushed at: over 6 years ago - Stars: 5 - Forks: 0
mikemadisonweb/yii2-rabbitmq
RabbitMQ Extension for Yii2
Language: PHP - Size: 184 KB - Last synced at: 15 days ago - Pushed at: about 2 years ago - Stars: 72 - Forks: 30
Valbou/Python_API_Consumer
REST API Consumer
Language: Python - Size: 80.1 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 4 - Forks: 0
neiro/kafkaHomeWork
Проект состоит из продюсера и двух консьюмеров для работы с Kafka-топиком my-topic. Один консьюмер использует pull-модель, а другой эмулирует push-модель.
Language: Java - Size: 25.4 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0
oussamahdidou/Cloud-Native-Solution-for-Inventory-and-Marketplace-and-Accounting-Service-Integration
Cloud-Native Solution for Inventory and Marketplace and Accounting Service Integration (.NET Core ,Spring Boot , React ,Aspire )
Language: C# - Size: 73.2 MB - Last synced at: about 2 months ago - Pushed at: 3 months ago - Stars: 1 - Forks: 0
nxdun/OSGI.chatte
P2P Chat App Using Java
Language: Java - Size: 272 KB - Last synced at: 15 days ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 1
g41797/beanstalkz
Zig client for Beanstalkd - simple and fast general purpose work queue
Language: Zig - Size: 685 KB - Last synced at: 6 days ago - Pushed at: 4 months ago - Stars: 5 - Forks: 0
Qihoo360/qbusbridge
The Apache Kafka Client SDK
Language: C++ - Size: 611 KB - Last synced at: 16 days ago - Pushed at: 12 months ago - Stars: 290 - Forks: 73
txix-open/grmq
High abstraction wrapper for Golang Rabbit MQ Client
Language: Go - Size: 96.7 KB - Last synced at: 12 days ago - Pushed at: 3 months ago - Stars: 6 - Forks: 2
jobcloud/php-kafka-lib
PHP Kafka producer / consumer library with PHP Avro support, based on php-rdkafka
Language: PHP - Size: 194 KB - Last synced at: 11 days ago - Pushed at: 27 days ago - Stars: 55 - Forks: 10
makasim/amqpextra
Golang AMQP reliable connection, publisher, consumer.
Language: Go - Size: 299 KB - Last synced at: 20 days ago - Pushed at: about 1 year ago - Stars: 74 - Forks: 18
mre/kafka-influxdb
High performance Kafka consumer for InfluxDB. Supports collectd message formats.
Language: Python - Size: 1.56 MB - Last synced at: 12 days ago - Pushed at: over 2 years ago - Stars: 215 - Forks: 53
SelimHorri/txt-to-speech-funny-random-jokes
Consume random jokes APIs and make them as a speech
Language: Python - Size: 1.95 KB - Last synced at: 9 days ago - Pushed at: almost 4 years ago - Stars: 13 - Forks: 0
joeycumines/go-bigbuff
Package bigbuff implements a one-many ordered queue producer-consumer pattern + utilities.
Language: Go - Size: 280 KB - Last synced at: 10 days ago - Pushed at: 4 months ago - Stars: 3 - Forks: 0
pjqdyd/react-boot
React Boot前端简单实现后端SpringBoot框架的核心
Language: TypeScript - Size: 323 KB - Last synced at: 25 days ago - Pushed at: 4 months ago - Stars: 2 - Forks: 0
toyokumo/gluttony
A consumer library using core.async and aws-api based on AWS SQS
Language: Clojure - Size: 87.9 KB - Last synced at: 20 days ago - Pushed at: 10 months ago - Stars: 3 - Forks: 1
vit0rr/publish-and-consume
Go project using RabbitMQ to publish messages and consume them
Language: Go - Size: 333 KB - Last synced at: 11 days ago - Pushed at: 4 months ago - Stars: 2 - Forks: 0
well-balanced/c-producer-consumer
producer & consumer pattern written in C
Language: C - Size: 3.91 KB - Last synced at: 3 days ago - Pushed at: about 3 years ago - Stars: 1 - Forks: 0
Abdulsametileri/cdc-pact-gophercon-2021
How to write CDC test using Pact in Go? 🤔
Language: Go - Size: 837 KB - Last synced at: 19 days ago - Pushed at: over 3 years ago - Stars: 54 - Forks: 8
devatherock/utilities
Utility scripts to perform common, repetitive tasks
Language: Groovy - Size: 200 KB - Last synced at: 9 days ago - Pushed at: 4 months ago - Stars: 4 - Forks: 0
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: 392 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 41 - Forks: 9
thecuriousresearcher/thecuriousresearcher.github.io
Language: Ruby - Size: 211 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 1 - Forks: 0
MarwanAlsoltany/amqp-agent
An elegant wrapper around the famous php-amqplib for 90% use case.
Language: PHP - Size: 1.35 MB - Last synced at: 3 months ago - Pushed at: almost 3 years ago - Stars: 16 - Forks: 0
swarajkumarsingh/go-email-consumer-aws-sqs
Production ready dynamic Golang email consumer service with AWS SQS(Simple Queue Service) & AWS SES(Simple Email Service) written in Golang for high availability, scaling & blazing fast performance , Dockerized for easy development & Deployment
Language: Go - Size: 15.6 KB - Last synced at: about 1 month ago - Pushed at: 4 months ago - Stars: 2 - Forks: 0
roadrunner-php/jobs
:electric_plug: RoadRunner Jobs (Queue) SDK
Language: PHP - Size: 261 KB - Last synced at: 16 days ago - Pushed at: 5 months ago - Stars: 23 - Forks: 13
HemaDeviU/Sounds-Good
Listen-to-Earn Podcast Streaming Dapp to support Creators
Language: TypeScript - Size: 3.01 MB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 0 - Forks: 0
osskit/dafka-consumer
Dockerized Kafka consumer
Language: Java - Size: 15.8 MB - Last synced at: 19 days ago - Pushed at: 5 months ago - Stars: 8 - Forks: 2
skroutz/rafka-rb
Ruby client library for Rafka
Language: Ruby - Size: 137 KB - Last synced at: 4 days ago - Pushed at: over 5 years ago - Stars: 9 - Forks: 5
yidas/codeigniter-queue-worker
CodeIgniter 3 Daemon Queue Worker (Consumer) Management Controller
Language: PHP - Size: 99.6 KB - Last synced at: 14 days ago - Pushed at: almost 2 years ago - Stars: 95 - Forks: 32
softonic/laravel-amqp-consumer 📦
Laravel package to handle the consumption of AMQP messages
Language: PHP - Size: 17.6 KB - Last synced at: 4 months ago - Pushed at: 5 months ago - Stars: 3 - Forks: 0
XbyOrange/mercury
Reactive CRUD data abstraction layer
Language: JavaScript - Size: 1.83 MB - Last synced at: 23 days ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 0
