All Categories → Control Flow → consumer

Top 45 consumer open source projects

Confluent Kafka Go

Confluent's Apache Kafka Golang client

✭ 3,047

go c HTML kafka-client consumer confluent librdkafka producer golang-bindings

Kafka Influxdb

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

✭ 206

python performance influxdb logstash consumer kafka-consumer

Qmq

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

✭ 2,420

java C#C++erlang shell Makefile kafka rabbitmq event-driven event message-queue message message-bus mq consumer distributed-transactions event-bus producer xa message-driven

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

✭ 183

scala security monitoring authentication kafka datadog akka-http consumer

Simpleue

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

✭ 124

aws redis queue workers worker consumer sqs

Kafka Zk Restapi

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

✭ 121

java rest kafka restful-api zookeeper consumer topic

Ngx Context

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

✭ 118

typescript angular utility context data-binding consumer

Kafka Flow

KafkaFlow is a .NET framework to consume and produce Kafka messages with multi-threading support. It's very simple to use and very extendable. You just need to install, configure, start/stop the bus with your app and create a middleware/handler to process the messages.

✭ 118

csharp dotnet kafka dotnet-core nuget workers consumer

Swarrotbundle

A symfony bundle for swarrot integration

✭ 89

symfony rabbitmq symfony-bundle bundle consumer

Rabbitmqbundle

RabbitMQ Bundle for the Symfony2 web framework

✭ 1,125

rabbitmq messaging amqp consumer

Go Workerpool

Worker pool implementation

✭ 62

go golang high-performance consumer

Lifion Kinesis

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

✭ 54

javascript aws client big-data amazon consumer

Yii2 Rabbitmq

RabbitMQ Extension for Yii2

✭ 52

rabbitmq yii2 exchange amqp yii2-extension workers callback consumer

Anotherkafkamonitor Akm

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

✭ 36

java kafka zookeeper consumer kafka-producer

Sarama Cluster

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

✭ 969

go kafka deprecated consumer

Aidp

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

✭ 20

lua server kafka consumer

Librdkafka

The Apache Kafka C/C++ library

✭ 5,617

c C++shell python CMake Makefile kafka high-performance apache-kafka consumer kafka-producer kafka-consumer librdkafka

Pact broker

Enables your consumer driven contracts workflow

✭ 540

ruby hacktoberfest verification consumer

Zerocode

A community-developed, free, open source, microservices API automation and load testing framework built using JUnit core runners for Http REST, SOAP, Security, Database, Kafka and much more. Zerocode Open Source enables you to create, change, orchestrate and maintain your automated test cases declaratively with absolute ease.

✭ 482

java dsl declarative api json framework testing http automation rest kafka stream assertions soap runner consumer

Kafka Go

Kafka library in Go

✭ 4,200

go kafka segment kafka-client consumer producer golang-native

Oauth 1.0a

OAuth 1.0a Request Authorization for Node and Browser

✭ 293

javascript oauth signature consumer

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.

✭ 274

go kafka prometheus prometheus-exporter exporter consumer group

Qbusbridge

The Apache Kafka Client SDK

✭ 272

python golang cplusplus kafka consumer kafka-producer kafka-consumer

Node Sinek

🎩 Most advanced high level Node.js Kafka client

✭ 262

typescript nodejs kafka ssl easy kafka-client consumer

Consumer

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

✭ 16

java consumer

codeigniter-queue-worker

CodeIgniter 3 Daemon Queue Worker (Consumer) Management Controller

✭ 67

PHP Io codeigniter workers listener consumer multi-process codeigniter-queue-worker manage-workers

Insulator

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

✭ 53

kotlin python ui schema kafka avro topic javafx consumer kafka-consumer apache-kafka tornadofx

amqpextra

Golang AMQP on steroids. Reliable connection. Publisher. Consumer.

✭ 59

go rabbitmq amqp publisher consumer hacktoberfest streadway

awesome-contract-testing

Awesome resources for Consumer-Driven Contract Testing

✭ 54

provider consumer pact cdc consumer-driven-contracts pact-broker

rocketmq

RocketMQ client for go supportting producer and consumer.

✭ 29

consumer producer rocketmq

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 .

sqs-quooler

A complete queue consumer for SQS

✭ 23

javascript Dockerfile aws sqs consumer

php-kafka-lib

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

✭ 38

PHP kafka avro consumer producer avro-support

rejected

rejected is a consumer framework for RabbitMQ

✭ 56

python shell framework rabbitmq amqp consumer hacktoberfest

pulsar-flex

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

✭ 43

javascript nodejs client library consumer pulsar producer

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.

✭ 32

HTML api security data standards consumer banking maintenance infosec cdr right

rabbitmq-consumer

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

✭ 25

rust mysql cli commands consumer rabbitmq-consumer

aws-kinesis-consumer

Consume an AWS Kinesis Data Stream to look over the records from a terminal.

✭ 23

python Dockerfile shell aws stream kinesis aws-cli consumer kinesis-stream kinesis-consumer aws-kinesis-consumer

ember-contextual-services

Services in Ember are scoped to the app as a whole and are singletons. Sometimes you don't want that. :) This addon provides ephemeral route-based services.

✭ 20