producer
There are 215 repositories under producer topic.
segmentio/kafka-go
Kafka library in Go
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) 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
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
confluentinc/confluent-kafka-javascript
Confluent's Apache Kafka JavaScript client
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++.
sevennt/rocketmq
RocketMQ client for go supportting producer and consumer.
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
1995parham/saf
Using NATS Jetstream as queue manager to replace RabbitMQ, etc.
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
davidcampos/kafka-spark-flink-example
Kafka streaming with Spark and Flink example
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
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
PHPMessageBus/eventbus-queue
Event Bus asynchronous queuing with many Producer and Consumer implementations
ulfox/kafka-video-stream
Video streaming with kafka
wgarunap/generic-kafka-event-producer
Rest Api based kafka event producer that supports multiple encoding types including Avro, Json, MessagePack, String & Bytes.
loftwah/download-my-music
A repo that shows how you can use youtube-dl to download my music for free!
php-kafka/php-simple-kafka-lib
PHP Kafka producer / consumer library with PHP Avro support, based on php-simple-kafka-client