confluent-kafka-go is Confluent's Golang client for Apache Kafka and the Confluent Platform.High performance - confluent-kafka-go is a lightweight wrapper around librdkafka, a finely tuned C client.
confluent golang-library golang-bindings librdkafka kafka-client consumer producer kafka-library kafkaProzess is a kafka library for Node.js
kafka producer consumer kafka-client kafka-librarySimple scaffolding for applications that produce SQS messages
aws sqs producer queueA KPL-like batch producer for Amazon Kinesis built on top of the official Go AWS SDK and using the same aggregation format that KPL use.
kpl amazon-kinesis kpl-aggregation kinesis producer kinesis-producerA Kafka consumer for InfluxDB written in Python. Supports InfluxDB 0.9.x and up. For InfluxDB 0.8.x support, check out the 0.3.0 tag. Kafka will serve as a buffer for your metric data during high load. Also it's useful for sending metrics from offshore data centers with unreliable connections to your monitoring backend.
kafka-influxdb kafka-consumer logstash influxdb producer consumer performanceThere once was a Kinesis readable stream without a home, and a Kinesis writable stream without a home, so now they're roommates. NOTE: Kinesis was a bad idea, and we're switching to Kafka. So I won't be using my own library for much longer.
aws kinesis nodejs stream readable writable kcl kpl consumer producerFrizzle is a magic message (Msg) bus designed for parallel processing with many goroutines. Start with the example implementation which shows a simple canonical implementation of a Processor on top of Frizzle and most of the core functions.
golang-library message-bus pipeline stream-processing streaming-data kafka kinesis consumer producerThin Amplib utils for RabbitMQ RPC in Node.js. Uses replyTo and correlationId message properties as the RabbitMQ rpc tutorial suggests. Make an rpc request, publish a message to an rpc queue.
rabbitmq rabbit bunny amqp amqplib client producer rpc produce message headers properties replyto correlationid timeoutThe library is implemented in top of librdkafka which is a C library implementation of the Apache Kafka protocol designed with message delivery reliability and high performance in mind, current figures exceed 1 million msgs/second for the producer and 3 million msgs/second for the consumer. It's well known that NIF's can affect the Erlang schedulers performances in case the functions are not returning in less than 1-2 ms and blocks the scheduler threads.
kafka librdkafka producer consumerNavigate to the cxx/c installation directory,and run build.sh -release, you will get a new file named libqbus.so in the "./lib/release" directory. Navigate to the Go installation directory,and run build.sh, you will get the new files qbus.go and libQBus_go.so in the directory "gopath/src/qbus".
kafka consumer producer kafkaclient kafkasdk cplusplus kafkabridge kafka-producer kafka-consumeris gregor's sister that adds a threadpool and a scheduler
kafka concurrency consumer thread-pool producer
We have large collection of open source products. Follow the tags from
Tag Cloud >>
Open source products are scattered around the web. Please provide information
about the open source projects you own / you use.
Add Projects.