producer

confluentinc/confluent-kafka-go

Confluent's Apache Kafka Golang client

qunarcorp/qmq

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

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:

nodefluent/node-sinek

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

Qihoo360/qbusbridge

The Apache Kafka Client SDK

mre/kafka-influxdb

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

hyeonsangjeon/youtube-dl-nas

youtube download queue websocket server with login for private NAS.

a8m/kinesis-producer

An aggregated records producer for Amazon Kinesis

confluentinc/confluent-kafka-javascript

Confluent's Apache Kafka JavaScript client

robinjoseph08/redisqueue

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

davidmarquis/redisq

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

oslabs-beta/AtomicKafka

silviucpp/erlkaf

Erlang kafka driver based on librdkafka

qianguozheng/go-workerpool

Worker pool implementation

jobcloud/php-kafka-lib

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

ayeo-flex-org/pulsar-flex

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

1995parham/saf

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

davidcampos/kafka-spark-flink-example

Kafka streaming with Spark and Flink example

sevennt/rocketmq

RocketMQ client for go supportting producer and consumer.

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

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

php-kafka/php-simple-kafka-client

PHP Kafka extension, supports also Redpanda

flolu/kafka

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

samber/go-amqp-pubsub

Fault tolerant Pub/Sub library for RabbitMQ

ricardo-ch/go-kafka

go-kafka facilitates Kafka listener implementation with multiple choice of retry pattern and producer above sarama

tolitius/grete

kafka client with threads and a scheduler

qntfy/frizzle

The magic message bus

ujjawal-khare-27/ray-kafka-producer

Efficient Pandas and Ray Kafka Producer for python using actor model.

116davinder/apache-kafka-backup-and-restore

It will take backup of given topic and store that into either local filesystem or S3.It will also restore from given local filesystem or S3.

qntfy/frafka

Frizzle for Apache Kafka

suredone/qdone

Command line job queue for SQS

bbusse/spotify-song-credits

Get spotify song credit data like performer, writer, producer

PHPMessageBus/eventbus-queue

Event Bus asynchronous queuing with many Producer and Consumer implementations

classcompliant/awesome-dj-producer

Manually curated collection of tools, resources and tutorials for nerdy DJs and Producers.

php-kafka/php-simple-kafka-lib

PHP Kafka producer / consumer library with PHP Avro support, based on php-simple-kafka-client