Displaying 1 to 20 from 37 results

librdkafka - The Apache Kafka C/C++ library

  •    C

Copyright (c) 2012-2016, Magnus Edenhill.librdkafka is a C library implementation of the Apache Kafka protocol, containing both Producer and Consumer support. It was 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.

kafka-node - Node.js client for Apache Kafka 0.8 and later.

  •    Javascript

Kafka-node is a Node.js client with Zookeeper integration for Apache Kafka 0.8.1 and later. Follow the instructions on the Kafka wiki to build Kafka 0.8 and get a test broker up and running.

coworkers - A RabbitMQ Microservice Framework in Node.js

  •    Javascript

Coworkers is a new microservice framework heavily inspired by Koa, which aims to be a simple, robust, and scalable foundation for creating RabbitMQ microservices. Through leveraging generators Coworkers allows you to ditch callbacks and greatly increase error-handling. Coworkers also uses Amqplib, a battle-tested AMQP client, under the hood to communicate with RabbitMQ and has best-practices baked in. Finally, Coworkers enables easy scalability by running each queue-consumer in its own process through node clustering (optional). Note: amqplib is a peer dependency. This give you flexibility in using any compatible version you please. npm@^3 does not install peer dependencies automatically, so you will have to install amqplib yourself.

sqs-consumer - Build SQS-based Node applications without the boilerplate

  •    Javascript

Build SQS-based applications without the boilerplate. Just define a function that receives an SQS message and call a callback when the message has been processed.Creates a new SQS consumer.

sarama-cluster - Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9

  •    Go

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 (and later). You need to install Ginkgo & Gomega to run tests. Please see http://onsi.github.io/ginkgo for more details.

pact_broker - Enables your consumer driven contracts workflow

  •    Ruby

The Pact Broker is an application for sharing for consumer driven contracts and verification results. It is optimised for use with "pacts" (contracts created by the Pact framework), but can be used for any type of contract that can be serialized to JSON. Contract testing is an alternative approach to traditional integration testing that gives you tests that are quicker to execute, and that are more maintainable at scale. One down side of the approach is that the important information that would be available all in one place at the end of an integration test suite execution (that is, the version numbers of all the applications that were tested together, and whether the tests passed or failed) is now spread out across many different builds. The Pact Broker is a tool that brings all this information back together again, and allows you to deploy with safety.

Community Bridge 2 (Answers)


Community project for accessing the MS Answers-Forums (http://answers.microsoft.com/) with any NNTP client. It provides an NNTP server (bridge) for the forums.

confluent-kafka-go - Confluent's Apache Kafka Golang client

  •    Go

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.

oauth-1.0a - OAuth 1.0a Request Authorization for Node and Browser

  •    Javascript

No more headache about OAuth 1.0a's stuff or "oauth_consumer_key, oauth_nonce, oauth_signature...." parameters, just use your familiar HTTP client to send OAuth requests. Starting with version 2.0.0, crypto/hash stuff is separated. oauth-1.0a will use your hash_function to sign.

consumer-contracts - Consumer-driven contracts in JavaScript

  •    Javascript

Consumer-driven contracts let you move fast without breaking things.API consumers codify their expections of your service in an executable contract. This defines the type of response that they expect for a given request. Contracts give you an insight into which parts of your API clients depend on, and which parts can be changed without fear of breaking them.

messaging-polyglot - RabbitMQ Messaging Polyglot with Java, ColdFusion, CommandBox, Groovy and more

  •    ColdFusion

Invoke the sbin/rabbitmq-server shell script. You can also start the server in detached mode with rabbitmq-server -detached, in which case the server process runs in the background.

pulsar-queue - Asynchronous message queue consumer and scheduler

  •    Python

Asynchronous server for consuming asynchronous IO tasks, green IO tasks, blocking IO tasks and long running CPU bound tasks. Create the modules where Jobs are implemented. It can be a directory containing several submodules.

abaaso - abaaso is a modern, lightweight Enterprise class RESTful JavaScript application framework.

  •    Javascript

abaaso is a modern, lightweight Enterprise class RESTful JavaScript application framework. If you're having problems, use the support forum at CodersClan.

rejected - rejected is a consumer framework for RabbitMQ

  •    Python

Rejected is a AMQP consumer daemon and message processing framework. It allows for rapid development of message processing consumers by handling all of the core functionality of communicating with RabbitMQ and management of consumer processes. Rejected runs as a master process with multiple consumer configurations that are each run it an isolated process. It has the ability to collect statistical data from the consumer processes and report on it.

kafka-influxdb - High performance Kafka consumer for InfluxDB. Supports collectd message formats.

  •    Python

A 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.

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

  •    Java

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

borges - borges collects and stores Git repositories.

  •    Go

borges collects and stores Git repositories. I have always imagined that Paradise will be a kind of library.

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.