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:

Language: Java - Size: 4.78 MB - Last synced: about 7 hours ago - Pushed: about 8 hours ago - Stars: 850 - Forks: 365

confluentinc/confluent-kafka-javascript

Confluent's Apache Kafka JavaScript client

Language: JavaScript - Size: 1.85 MB - Last synced: about 21 hours ago - Pushed: 1 day ago - Stars: 68 - Forks: 3

gmr/rejected

rejected is a consumer framework for RabbitMQ

Language: Python - Size: 1.18 MB - Last synced: 6 days ago - Pushed: about 2 months ago - Stars: 58 - Forks: 18

eharrow/amq-queue-drainer-ts

Drain AMQP message queues

Language: TypeScript - Size: 1000 KB - Last synced: 1 day ago - Pushed: 1 day ago - Stars: 1 - Forks: 0

1995parham/saf

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

Language: Go - Size: 647 KB - Last synced: about 14 hours ago - Pushed: 1 day ago - Stars: 27 - Forks: 5

confluentinc/librdkafka

The Apache Kafka C/C++ library

Language: C - Size: 30.6 MB - Last synced: 3 days ago - Pushed: 3 days ago - Stars: 7,297 - Forks: 3,109

senapeksin/RabbitMQ_Studies

RabbitMQ-Tutorials

Language: C# - Size: 26.4 KB - Last synced: 3 days ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

tyolab/tyo-mq-client-python

A TYO-MQ client for python

Language: Python - Size: 74.2 KB - Last synced: 3 days ago - Pushed: 4 days ago - Stars: 0 - Forks: 0

castor-labs/queue

A simple queue abstraction for your PHP projects

Language: PHP - Size: 37.1 KB - Last synced: 5 days ago - Pushed: almost 3 years ago - Stars: 1 - Forks: 0

victoryama/exercise3-java-section20

Java programming exercises from Section 20 - Java Course by Nelio Alves

Language: Java - Size: 4.88 KB - Last synced: 5 days ago - Pushed: 5 days ago - Stars: 0 - Forks: 0

sandeep-kollipara/computer-vision-client

[Phase II: Consumer] This repository holds the code developed in partial fulfilment of online credit course "CS370 - OS" offered at Colorado State University Online for Spring 2024.

Language: Python - Size: 1.27 MB - Last synced: 5 days ago - Pushed: 6 days ago - Stars: 0 - Forks: 0

2KAbhishek/recrud

CRUD React Consumer 🍦🌐

Language: JavaScript - Size: 511 KB - Last synced: 6 days ago - Pushed: about 1 month ago - Stars: 1 - Forks: 0

ChiefGokhlayeh/tap-consooomer

📦 Test Anything Protocol Consumer for Rust

Language: Rust - Size: 229 KB - Last synced: 7 days ago - Pushed: 8 days ago - Stars: 2 - Forks: 0

areed1192/td-ameritrade-python-api

Unofficial Python API client library for TD Ameritrade. This library allows for easy access of the Standard API and allows users to build data pipelines for the Streaming API.

Language: Python - Size: 2 MB - Last synced: 6 days ago - Pushed: 12 months ago - Stars: 683 - Forks: 254

php-amqplib/RabbitMqBundle

RabbitMQ Bundle for the Symfony web framework

Language: PHP - Size: 960 KB - Last synced: 6 days ago - Pushed: about 1 month ago - Stars: 1,218 - Forks: 470

FINTLabs/fint-core-consumer-administrasjon-personal

Language: Java - Size: 154 KB - Last synced: 12 days ago - Pushed: 12 days ago - Stars: 0 - Forks: 0

joeycumines/go-bigbuff

Package bigbuff implements a one-many ordered queue producer-consumer pattern + utilities.

Language: Go - Size: 198 KB - Last synced: 12 days ago - Pushed: 13 days ago - Stars: 3 - Forks: 0

CPAD-Gazipur/Weather

This is a weather App where user can see weather update of any country form the world. Even the icon & background image is changeable according to weather condition.

Language: Dart - Size: 24.5 MB - Last synced: 14 days ago - Pushed: almost 2 years ago - Stars: 1 - Forks: 0

bluekiri/kafka-client

Simple Apache Kafka client capable of consume from and produce to a topic with support of protobuf messages.

Language: Go - Size: 255 KB - Last synced: 10 days ago - Pushed: 4 months ago - Stars: 0 - Forks: 0

2KAbhishek/pact-order-test

Contract Based Tests with Pact 🧪✅

Language: JavaScript - Size: 456 KB - Last synced: 6 days ago - Pushed: 14 days ago - Stars: 0 - Forks: 0

ConsumerDataStandardsAustralia/standards-maintenance

This repository houses the interactions, consultations and work management to support the maintenance of baselined components of the Consumer Data Right API Standards and Information Security profile.

Language: HTML - Size: 388 KB - Last synced: 14 days ago - Pushed: 14 days ago - Stars: 41 - Forks: 9

silviucpp/erlkaf

Erlang kafka driver based on librdkafka

Language: Erlang - Size: 233 KB - Last synced: 14 days ago - Pushed: 14 days ago - Stars: 81 - Forks: 39

stepanowon/OAuth10aProvider

Spring 4.3 으로 만든 OAuth 1.0a Provider, Consumer 예제

Language: Java - Size: 516 KB - Last synced: 14 days ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

durmazoguzhan/RabbitMQConsumerInveon

Inveon Bootcamp - RabbitMQ Consumer Example

Language: C# - Size: 6.84 KB - Last synced: 14 days ago - Pushed: 6 months ago - Stars: 0 - Forks: 0

repository-service-tuf/repository-service-tuf-worker

Repository Service for TUF: Worker

Language: Python - Size: 2.36 MB - Last synced: 15 days ago - Pushed: 16 days ago - Stars: 9 - Forks: 15

97arushisharma/Apache_Pulsar

This repository contains the sample apache pulsar producer and consumer with various properties enabled.

Language: Java - Size: 24.4 KB - Last synced: 15 days ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

FINTLabs/fint-core-consumer-utdanning-vurdering

Language: Java - Size: 266 KB - Last synced: 14 days ago - Pushed: 15 days ago - Stars: 0 - Forks: 0

alipolatli/some-rabbitmq

First look at RabbitMQ and its experiments and project. It stands as a legacy.

Language: C# - Size: 1.66 MB - Last synced: 16 days ago - Pushed: 18 days ago - Stars: 0 - Forks: 0

prashanth-sams/pact-jvm-boilerplate

Pact based consumer driven contract testing boilerplate on spring boot applications

Language: Java - Size: 66.4 KB - Last synced: 17 days ago - Pushed: almost 3 years ago - Stars: 1 - Forks: 1

flolu/kafka

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

Language: TypeScript - Size: 290 KB - Last synced: 6 days ago - Pushed: over 1 year ago - Stars: 15 - Forks: 8

conorheffron/rabbitmq-tester

Tool for testing RabbitMQ instance.

Language: Java - Size: 49.8 KB - Last synced: 18 days ago - Pushed: 19 days ago - Stars: 1 - Forks: 0

kafkesc/kommitted

Measure Kafka Consumer Offset Lag and Time Lag

Language: Rust - Size: 381 KB - Last synced: 1 day ago - Pushed: 1 day ago - Stars: 6 - Forks: 0

devatherock/utilities

Utility scripts to perform common, repetitive tasks

Language: Groovy - Size: 166 KB - Last synced: 18 days ago - Pushed: 18 days ago - Stars: 4 - Forks: 0

ddo/oauth-1.0a

OAuth 1.0a Request Authorization for Node and Browser

Language: JavaScript - Size: 262 KB - Last synced: 5 days ago - Pushed: 5 months ago - Stars: 322 - Forks: 118

jobatator/php

The Jobatator PHP Client

Language: PHP - Size: 29.3 KB - Last synced: 19 days ago - Pushed: about 3 years ago - Stars: 1 - Forks: 0

danielspinard/wordlist-consumer

A smart consumer capable of consuming word lists and returning an almost real object(Person, Address, Company).

Language: PHP - Size: 321 KB - Last synced: 19 days ago - Pushed: almost 3 years ago - Stars: 2 - Forks: 0

qunarcorp/qmq

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

Language: Java - Size: 6.92 MB - Last synced: 19 days ago - Pushed: 5 months ago - Stars: 2,774 - Forks: 692

maheshwari-dhruv/Credit-Card-Transaction-Parser

Credit Card Transaction Parser - Full stack parser project with reactjs and spring boot 3. This projects parse the credit-card transactions and kafka is used to produce and consume the parse data.

Language: Java - Size: 109 KB - Last synced: 18 days ago - Pushed: 10 months ago - Stars: 1 - Forks: 0

shrp777/rabbitmq_expressjs_provider_consumer_service

Rabbit MQ Provider / Consumer Services (Docker + Node.js + Express.js)

Language: JavaScript - Size: 27.3 KB - Last synced: 20 days ago - Pushed: 4 months ago - Stars: 0 - Forks: 0

klippx/phobosjs-mock

Language: JavaScript - Size: 11.7 KB - Last synced: 20 days ago - Pushed: over 6 years ago - Stars: 0 - Forks: 0

emirhandogandemir/functionalProgramming

to Declarative Programming from Imperative Programming

Language: Java - Size: 26.4 KB - Last synced: 20 days ago - Pushed: over 2 years ago - Stars: 2 - Forks: 0

pact-foundation/pact_broker

Enables your consumer driven contracts workflow

Language: Ruby - Size: 11.2 MB - Last synced: 24 days ago - Pushed: about 1 month ago - Stars: 693 - Forks: 172

FINTLabs/fint-core-consumer-utdanning-larling

Language: Java - Size: 203 KB - Last synced: 21 days ago - Pushed: 21 days ago - Stars: 0 - Forks: 0

maikeulb/pokemon

Consumer for pokeapi

Language: Python - Size: 60.5 KB - Last synced: 22 days ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

maikeulb/city-bikes

Consumer for City Bike API

Language: Go - Size: 12.7 MB - Last synced: 22 days ago - Pushed: about 6 years ago - Stars: 0 - Forks: 0

JaSei/RabbitMQ-Consumer-Batcher

Language: Perl - Size: 21.5 KB - Last synced: 22 days ago - Pushed: almost 7 years ago - Stars: 0 - Forks: 0

robinjoseph08/redisqueue

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

Language: Go - Size: 32.2 KB - Last synced: 7 days ago - Pushed: 2 months ago - Stars: 122 - Forks: 54

Farfetch/kafkaflow

Apache Kafka .NET Framework to create applications simple to use and extend.

Language: C# - Size: 21.4 MB - Last synced: 25 days ago - Pushed: 26 days ago - Stars: 572 - Forks: 99

cbartram/HealthKit-Consumer

Consumer Application to Receive published events from HealthKit's WatchOS application

Language: JavaScript - Size: 479 KB - Last synced: 23 days ago - Pushed: almost 2 years ago - Stars: 0 - Forks: 0

confluentinc/confluent-kafka-go

Confluent's Apache Kafka Golang client

Language: Go - Size: 297 MB - Last synced: 24 days ago - Pushed: 24 days ago - Stars: 4,409 - Forks: 642

NYPL/cancel-request-result-consumer 📦

PHP Lambda for processing canceling requests.

Language: PHP - Size: 8.2 MB - Last synced: 26 days ago - Pushed: about 2 years ago - Stars: 0 - Forks: 1

RiversideValley/Estella

Your sweet maid. 🐁🐭

Language: Svelte - Size: 2.44 MB - Last synced: 6 days ago - Pushed: 12 months ago - Stars: 0 - Forks: 0

mendrugory/galena

Galena is a topic producer-consumer library built on top of GenStage for Elixir.

Language: Elixir - Size: 26.4 KB - Last synced: 6 days ago - Pushed: over 6 years ago - Stars: 6 - Forks: 0

GitDeveloperBel/Kafka-school-experiment

Project using Confluent Kafka for school

Language: C# - Size: 94.7 KB - Last synced: 27 days ago - Pushed: almost 2 years ago - Stars: 0 - Forks: 0

clara-jr/redismb

Redis Message Broker for Event-Driven Architecture using Redis Streams

Language: JavaScript - Size: 205 KB - Last synced: 14 days ago - Pushed: 26 days ago - Stars: 0 - Forks: 0

FINTLabs/fint-core-consumer-personvern-samtykke

Language: Java - Size: 183 KB - Last synced: 28 days ago - Pushed: 2 months ago - Stars: 2 - Forks: 0

FINTLabs/fint-core-consumer-personvern-kodeverk

Language: Java - Size: 126 KB - Last synced: 28 days ago - Pushed: 2 months ago - Stars: 0 - Forks: 0

swarajkumarsingh/go-email-consumer-aws-sqs

Production ready dynamic Golang email consumer service with AWS SQS(Simple Queue Service) & AWS SES(Simple Email Service) written in Golang for high availability, scaling & blazing fast performance , Dockerized for easy development & Deployment

Language: Go - Size: 13.7 KB - Last synced: 29 days ago - Pushed: 29 days ago - Stars: 0 - Forks: 0

cevio/dubbo.ts

阿里巴巴 dubbo 协议的NodeJS版实现：一套完整的从Provider到consumer的解决方案，高性能支持高QPS。

Language: TypeScript - Size: 336 KB - Last synced: about 16 hours ago - Pushed: over 3 years ago - Stars: 135 - Forks: 14

segmentio/kafka-go

Kafka library in Go

Language: Go - Size: 2.12 MB - Last synced: 30 days ago - Pushed: about 2 months ago - Stars: 7,062 - Forks: 742

oslabs-beta/AtomicKafka

Language: JavaScript - Size: 949 KB - Last synced: 3 days ago - Pushed: over 1 year ago - Stars: 107 - Forks: 16

domwood/kiwi-kafka

kiwi-kafka - A Kafka Web Interface

Language: Java - Size: 3.95 MB - Last synced: 5 days ago - Pushed: 6 days ago - Stars: 12 - Forks: 7

afonsir/rss-parser-consumer

Basic Go consumer (Pub/Sub)

Language: Go - Size: 4.88 KB - Last synced: about 1 month ago - Pushed: about 2 years ago - Stars: 0 - Forks: 0

redpanda-data/kminion

KMinion is a feature-rich Prometheus exporter for Apache Kafka written in Go. It is lightweight and highly configurable so that it will meet your requirements.

Language: Go - Size: 8.14 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 569 - Forks: 122

smok-serwis/coolamqp

Pure Python pretty fast AMQP client with sane reconnects

Language: Python - Size: 935 KB - Last synced: about 14 hours ago - Pushed: about 1 month ago - Stars: 6 - Forks: 0

roadrunner-php/jobs

:electric_plug: RoadRunner Jobs (Queue) SDK

Language: PHP - Size: 232 KB - Last synced: 26 days ago - Pushed: 26 days ago - Stars: 20 - Forks: 9

carloshenriquefs/picpay-simple

💸💳 - Challenge Picpay Simplified

Language: Java - Size: 83 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 0 - Forks: 0

php-strict/widgets-consumer

Widgets Consumer

Language: PHP - Size: 14.6 KB - Last synced: about 1 month ago - Pushed: almost 5 years ago - Stars: 1 - Forks: 0

txix-open/grmq

High abstraction wrapper for Golang Rabbit MQ Client

Language: Go - Size: 91.8 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 4 - Forks: 1

zalando-incubator/remora

Kafka consumer lag-checking application for monitoring, written in Scala and Akka HTTP; a wrap around the Kafka consumer group command. Integrations with Cloudwatch and Datadog. Authentication recently added

Language: Scala - Size: 157 KB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 197 - Forks: 31

qntfy/frafka

Frizzle for Apache Kafka

Language: Go - Size: 53.7 KB - Last synced: about 1 month ago - Pushed: over 3 years ago - Stars: 13 - Forks: 4

EmCarlss/HICP_Voyager

HICP Voyager - Inflation dashboard for the European HICP

Language: HTML - Size: 368 KB - Last synced: 19 days ago - Pushed: 19 days ago - Stars: 0 - Forks: 0

veritone/go-messaging-lib

Core library for interfacing with Veritone's eventing system in Golang

Language: Go - Size: 13.4 MB - Last synced: about 2 months ago - Pushed: over 4 years ago - Stars: 0 - Forks: 2

hsldymq/bugs-bunny

弹性的多进程RabbitMQ Consumer

Language: PHP - Size: 214 KB - Last synced: 23 days ago - Pushed: 24 days ago - Stars: 2 - Forks: 0

luszczynski/amq-demo

AMQ Broker (Artemis) and AMQ Streams (Kafka) Demo

Language: Java - Size: 4.88 MB - Last synced: about 2 months ago - Pushed: over 2 years ago - Stars: 0 - Forks: 1

zhaohanqing/kafkaLagsMetrics

Kafka Lags Metrics

Language: Java - Size: 15.6 KB - Last synced: about 2 months ago - Pushed: about 7 years ago - Stars: 1 - Forks: 1

hcanfly/solitaire_flutter

Solitaire is a version of the game written for Flutter in Dart. Updated to Flutter 2.5.3, Dart 2.14.4 with Null Safety, etc. Also updated app to use Providers with ChangeNotifier and Consumer.

Language: Dart - Size: 1.14 MB - Last synced: about 2 months ago - Pushed: over 2 years ago - Stars: 3 - Forks: 4

yidas/codeigniter-queue-worker

CodeIgniter 3 Daemon Queue Worker (Consumer) Management Controller

Language: PHP - Size: 99.6 KB - Last synced: 21 days ago - Pushed: 11 months ago - Stars: 88 - Forks: 31

mre/kafka-influxdb

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

Language: Python - Size: 1.56 MB - Last synced: 6 days ago - Pushed: over 1 year ago - Stars: 215 - Forks: 54

othmane099/Producer-ProducerConsumer-Consumer-Model

This is a simulation of the model Producer-ProducerConsumer-Consumer.

Language: C - Size: 5.86 KB - Last synced: about 2 months ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

jkone27/AliceMQ

A reactive client library for RabbitMQ and Google PubSub, with observables, acknowledge and reject capabilities

Language: C# - Size: 625 KB - Last synced: about 1 month ago - Pushed: about 2 months ago - Stars: 5 - Forks: 2

tolitius/grete

kafka client with threads and a scheduler

Language: Clojure - Size: 43.9 KB - Last synced: 1 day ago - Pushed: 5 months ago - Stars: 16 - Forks: 3

liburdi/kafka-consumer

kafka consumer for go

Language: Go - Size: 20.5 KB - Last synced: about 1 month ago - Pushed: about 2 months ago - Stars: 0 - Forks: 0

tusharnankani/Swadeshi

Implementing a Web Based solution through which farmers can participate in a commodity exchange market

Language: JavaScript - Size: 22.1 MB - Last synced: 6 days ago - Pushed: about 1 year ago - Stars: 21 - Forks: 6

hyeonsangjeon/youtube-dl-nas

youtube download queue websocket server with login for private NAS.

Language: Python - Size: 651 KB - Last synced: 17 days ago - Pushed: 12 months ago - Stars: 151 - Forks: 55

Trendyol/goncolos

Goncolos is simple wrapper top of confluent-kafka-dotnet

Language: C# - Size: 44.9 KB - Last synced: 21 days ago - Pushed: over 2 years ago - Stars: 4 - Forks: 1

turbomq/engine

A lightweight message queue engine

Language: C - Size: 104 KB - Last synced: about 2 months ago - Pushed: over 8 years ago - Stars: 9 - Forks: 2

samber/go-amqp-pubsub

Fault tolerant Pub/Sub library for RabbitMQ

Language: Go - Size: 609 KB - Last synced: 6 days ago - Pushed: about 2 months ago - Stars: 16 - Forks: 0

RAVI-CHANDRIKA-05/Whats-Trending-in-the-Food-Beverage-Industry

"Conducting a comprehensive evaluation of the North American food and beverage industry, analyzing market trends, emerging flavors, and consumer preferences to provide a holistic understanding of the regional F&B landscape."

Size: 4.94 MB - Last synced: 19 days ago - Pushed: 19 days ago - Stars: 0 - Forks: 0

zarnoevic/go-rabbitmq

A simple Go framework for RabbitMQ producer-consumer communication.

Language: Go - Size: 541 KB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 0 - Forks: 0

andreas-wagner-dev/kafka-server-embedded

Run an embedded kafka server as a local java programm with a producer and consumer example in a junit test.

Language: Java - Size: 31.3 KB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 0 - Forks: 0

davidmarquis/redisq

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

Language: Java - Size: 55.7 KB - Last synced: 21 days ago - Pushed: over 6 years ago - Stars: 99 - Forks: 36

sspathak/VoiceChat

a Python voice chat app that uses WebSockets to send encrypted data between a multi-threaded client and server

Language: Python - Size: 18.6 MB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 39 - Forks: 8

RoboSDK/Flow

Flow is a software framework focused on ease of use while maximizing performance in closed closed loop systems (e.g. robots). Flow is built on top of C++ 20 coroutines and utilizes modern C++ techniques.

Language: C++ - Size: 725 KB - Last synced: 6 days ago - Pushed: over 1 year ago - Stars: 9 - Forks: 0

lirantal/awesome-contract-testing

Awesome resources for Consumer-Driven Contract Testing

Size: 10.7 KB - Last synced: 21 days ago - Pushed: over 1 year ago - Stars: 73 - Forks: 9

calebboyd/redis-x-stream

An AsyncIterable interface for reading redis streams

Language: TypeScript - Size: 1.67 MB - Last synced: 24 days ago - Pushed: 9 months ago - Stars: 8 - Forks: 4

deepakkumarnd/sevak Fork of chillr/sevak

Battle tested plugin for creating Rabbitmq consumers in Ruby.

Language: Ruby - Size: 47.9 KB - Last synced: 3 months ago - Pushed: about 2 years ago - Stars: 1 - Forks: 0

ainy-rehman/largelanguagemodel_consumerbrand

This project utilizes a machine learning model where consumer brand data is employed. Initially, a preliminary model is developed, followed by a refined model using a process called 'fine-tuning' to improve results. Additionally, a comprehensive testing suite has been created to validate accuracy and reliability of the model's predictions.

Language: Jupyter Notebook - Size: 752 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 0 - Forks: 0

OderoOluoch/EasyEats-Angular

This is the front end for - Ann app that digitizes the ordering process of food at the NextGen Mall, whereby a client would go to the food court then place an order using a mobile web application right from their table.

Language: CSS - Size: 6.61 MB - Last synced: 3 months ago - Pushed: over 2 years ago - Stars: 0 - Forks: 1

bsm/sarama-cluster 📦

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]

Language: Go - Size: 331 KB - Last synced: 2 months ago - Pushed: over 4 years ago - Stars: 1,007 - Forks: 224