QMQ是去哪儿网内部广泛使用的消息中间件,自2012年诞生以来在去哪儿网所有业务场景中广泛的应用,包括跟交易息息相关的订单场景; 也包括报价搜索等高吞吐量场景。
#
producer
Repositories 68
Confluent's Apache Kafka Golang client
The Apache Kafka Client SDK
kafka
consumer
producer
kafkaclient
kafkasdk
cplusplus
php
python
golang
kafkabridge
kafka-producer
kafka-consumer
C++
Updated Apr 15, 2019
High performance Kafka consumer for InfluxDB. Supports collectd message formats.
JavaScript
Updated Apr 30, 2019
A community-developed, free, open source API automation testing framework built using Java JUnit core runners for Htt…
An aggregated records producer for Amazon Kinesis
RedisQ - Java implementation of a reliable Pub/Sub message queue based on Redis
Java
Updated Sep 4, 2017
Worker pool implementation
Go
Updated Sep 13, 2018
Erlang kafka driver based on librdkafka
Erlang
Updated Apr 22, 2019
一个高性能,可靠,异步的本地持久化队列实现;重启JVM、重启服务器、或者强制KILL进程时,队列里的数据不丢失;
Java
Updated Dec 4, 2017
RocketMQ client for go supportting producer and consumer.
youtube download queue websocket server with login for private NAS.
youtube
youtube-dl
nas
python
queue
websocket
bottle
docker
login
bootstrap
thread
async
consumer
producer
publisher
subscribe
login-system
Python
Updated Apr 25, 2019
The magic message bus
golang
golang-library
message-bus
pipeline
stream-processing
streaming-data
kafka
kinesis
consumer
producer
Go
Updated Mar 21, 2019
Command line job queue for SQS
Frizzle for Apache Kafka
Go
Updated Apr 24, 2019
Event Bus asynchronous queuing with many Producer and Consumer implementations
consumer
eventbus
supervisor
eventbus-queue
amqp-queue
producer
producer-consumer
queue
redisqueue
middleware
beanstalkd
rabbitmq
amqp
event-sourcing
event-driven
event-driven-microservices
event-driven-programming
php7
php
PHP
Updated Apr 16, 2017
Most simple way to test Kafka Streaming e.g. Read/Write during HBase/Hadoop or other Data Ingestion Pipe Lines
java
kafka
stream
integration
docker
topic
cluster
testing
json
raw
avro
schema
rest
proxy
producer
consumer
Java
Updated Mar 24, 2019
Galena is a topic producer-consumer library built on top of GenStage for Elixir.
Elixir
Updated Aug 16, 2017
nsq 生产者负载均衡,支持轮询、随机、平滑权重 让数据平均写入nsqd 减少数据丢失风险及提高机器使用率。
Go
Updated Oct 4, 2018
Capture video frame from IP Cam and send to Kinesis data streams for processing
Python
Updated Jan 6, 2018
A simple Kafka Producer
Scala
Updated Jul 10, 2017
Kafka streaming with Spark and Flink example
Java
Updated Nov 1, 2018
Simple AMQP abstraction for MVP projects
Go
Updated Dec 28, 2018
Sample Banking project for contract tests between target and interfacing applications. Also known as consumer driven …
java
rest
api
contract
testing
consumer
driven
based
producer
json
dsl
schema
assertion
assertions
compare
jenkins
build
tests
Java
Updated Sep 27, 2018
Java solution for producer and consumer problem
Java
Updated Dec 14, 2018
A simple TAP report producer based on event system. A plugin for `dush` event emitter or anything based on it
tap
tape
test-anything-protocol
producer
report
reporter
emitter
event-system
events
minibaseplugin
baseplugin
dushplugin
JavaScript
Updated Jul 20, 2017
Producer & Consumer simulation to experiment and learn threading.
C
Updated Jan 12, 2017
Frizzle for AWS Kinesis
Go
Updated Feb 8, 2019
Producer - Consumer simulation using unix mutex synchronisation on cyclic array
C
Updated Jan 26, 2017