consumer

confluentinc/confluent-kafka-go

Confluent's Apache Kafka Golang client

qunarcorp/qmq

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

php-amqplib/RabbitMqBundle

RabbitMQ Bundle for the Symfony web framework

bsm/sarama-cluster

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

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. Visit documentation below:

pact-foundation/pact_broker

Enables your consumer driven contracts workflow

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.

Farfetch/kafkaflow

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

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.

confluentinc/librdkafka

The Apache Kafka C/C++ library

ddo/oauth-1.0a

OAuth 1.0a Request Authorization for Node and Browser

Qihoo360/qbusbridge

The Apache Kafka Client SDK

nodefluent/node-sinek

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

mre/kafka-influxdb

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

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

hyeonsangjeon/youtube-dl-nas

youtube download queue websocket server with login for private NAS.

ng-turkey/ngx-context

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

cevio/dubbo.ts

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

robinjoseph08/redisqueue

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

javibravo/simpleue

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

gnuhpc/Kafka-zk-restapi

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

oslabs-beta/AtomicKafka

davidmarquis/redisq

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

confluentinc/confluent-kafka-javascript

Confluent's Apache Kafka JavaScript client

yidas/codeigniter-queue-worker

CodeIgniter 3 Daemon Queue Worker (Consumer) Management Controller

swarrot/SwarrotBundle

A symfony bundle for swarrot integration

lifion/lifion-kinesis

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

silviucpp/erlkaf

Erlang kafka driver based on librdkafka

lirantal/awesome-contract-testing

Awesome resources for Consumer-Driven Contract Testing

makasim/amqpextra

Golang AMQP reliable connection, publisher, consumer.

GokGokalp/MetroBus

Lightweight messaging wrapper of MassTransit

mikemadisonweb/yii2-rabbitmq

RabbitMQ Extension for Yii2

qianguozheng/go-workerpool

Worker pool implementation

quantmind/pulsar-queue

Asynchronous message queue consumer and scheduler

gmr/rejected

rejected is a consumer framework for RabbitMQ