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: about 1 month 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: about 1 month ago - Pushed: about 1 year ago - Stars: 151 - Forks: 55

Trendyol/goncolos

Goncolos is simple wrapper top of confluent-kafka-dotnet

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

samber/go-amqp-pubsub

Fault tolerant Pub/Sub library for RabbitMQ

Language: Go - Size: 609 KB - Last synced: about 1 month ago - Pushed: 3 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: about 1 month ago - Pushed: about 2 months ago - Stars: 0 - Forks: 0

zarnoevic/go-rabbitmq

A simple Go framework for RabbitMQ producer-consumer communication.

Language: Go - Size: 541 KB - Last synced: 3 months ago - Pushed: 3 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: 3 months ago - Pushed: 3 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: about 2 months 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: 3 months ago - Pushed: 3 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: about 1 month 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: about 2 months 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: 10 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: 4 months ago - Pushed: over 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: 4 months ago - Pushed: 4 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: 4 months ago - Pushed: almost 3 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: 3 months ago - Pushed: over 4 years ago - Stars: 1,007 - Forks: 224

facile-it/rabbitmq-consumer

A configurable RabbitMQ consumer made in Rust, useful for a stable and reliable CLI commands processor.

Language: Rust - Size: 201 KB - Last synced: 2 months ago - Pushed: about 3 years ago - Stars: 27 - Forks: 3

ashiksp/smart_que

RabbitMQ Queue Publisher & Consumer

Language: Ruby - Size: 50.8 KB - Last synced: 4 months ago - Pushed: almost 6 years ago - Stars: 0 - Forks: 0

quantmind/pulsar-queue 📦

Asynchronous message queue consumer and scheduler

Language: Python - Size: 863 KB - Last synced: 14 days ago - Pushed: over 6 years ago - Stars: 62 - Forks: 11

vfunin/rabbitmq-consumer

Go RabbitMQ consumser

Language: Go - Size: 7.81 KB - Last synced: 4 months ago - Pushed: almost 2 years ago - Stars: 1 - Forks: 0

bavix/go-kafka-comsume

Language: Go - Size: 20.5 KB - Last synced: 11 days ago - Pushed: 3 months ago - Stars: 0 - Forks: 0

ng-turkey/ngx-context

Angular Context: Easy property binding for router outlet and nested component trees.

Language: TypeScript - Size: 1.97 MB - Last synced: 30 days ago - Pushed: over 1 year ago - Stars: 134 - Forks: 9

jobcloud/php-kafka-lib

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

Language: PHP - Size: 188 KB - Last synced: about 1 month ago - Pushed: 6 months ago - Stars: 52 - Forks: 9

sylhare/kafka

Kafka experimentation

Language: Kotlin - Size: 321 KB - Last synced: 4 months ago - Pushed: 4 months ago - Stars: 3 - Forks: 0

dtemir/us-consumer-complaint

Bank Score.

Language: HTML - Size: 9.37 MB - Last synced: 2 months ago - Pushed: almost 3 years ago - Stars: 2 - Forks: 1

nodefluent/node-sinek

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

Language: TypeScript - Size: 1.17 MB - Last synced: 14 days ago - Pushed: over 1 year ago - Stars: 291 - Forks: 52

kamlesh9451/CoreJava

Multi threading code

Language: Java - Size: 45.9 KB - Last synced: 5 months ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

tommynurwantoro/kafkid

Kafka Messaging Service Helper. Including API Publisher and Subscriber Kafka

Language: Go - Size: 193 KB - Last synced: 4 months ago - Pushed: 5 months ago - Stars: 1 - Forks: 1

suredone/qdone

Command line job queue for SQS

Language: JavaScript - Size: 1.65 MB - Last synced: 12 days ago - Pushed: 12 days ago - Stars: 12 - Forks: 1

thinow/aws-kinesis-consumer

Consume an AWS Kinesis Data Stream to look over the records from a terminal.

Language: Python - Size: 146 KB - Last synced: 28 days ago - Pushed: 10 months ago - Stars: 24 - Forks: 0

sichkar-valentyn/Transportation_Problem

Transportation Model for an optimal strategy for distributing a commodity from a group of supply centers to various receiving centers. Solved in C# Windows Form Application

Language: C# - Size: 732 KB - Last synced: 4 months ago - Pushed: almost 5 years ago - Stars: 12 - Forks: 4

AndreaPrestia/FelisMq

A library that uses the MQTT listener such a consumer by topic

Language: C# - Size: 16.6 KB - Last synced: 5 months ago - Pushed: 5 months ago - Stars: 0 - Forks: 0

websublime/kong-console 📦

Angular 2 UI console for getkong.org

Language: CSS - Size: 6.26 MB - Last synced: 2 months ago - Pushed: over 7 years ago - Stars: 13 - Forks: 3

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

Language: Java - Size: 299 KB - Last synced: about 2 months ago - Pushed: 12 months ago - Stars: 28 - Forks: 4

hanshengjiang/Reference_Effects

Software package for intertemporal pricing optimization under reference effects and consumer heterogeneity estimation. Please see REAMDE.md for more details.

Language: Python - Size: 3.78 MB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 9 - Forks: 0

mikemadisonweb/yii2-rabbitmq

RabbitMQ Extension for Yii2

Language: PHP - Size: 184 KB - Last synced: 14 days ago - Pushed: about 1 year ago - Stars: 72 - Forks: 31

ferpetrelli/eloquent-consumer

API consumer and query builder with an Eloquent like syntax

Language: PHP - Size: 34.2 KB - Last synced: about 2 months ago - Pushed: over 5 years ago - Stars: 6 - Forks: 3

onetransistor/MediaKeyboard

STM32 Arduino Library with support for USB consumer control device (media keys)

Language: C - Size: 33.2 KB - Last synced: 5 months ago - Pushed: almost 4 years ago - Stars: 13 - Forks: 3

qntfy/frizzle

The magic message bus

Language: Go - Size: 34.2 KB - Last synced: 2 months ago - Pushed: about 5 years ago - Stars: 15 - Forks: 4

techshot25/BlackFriday

Shopping behavior data analysis

Language: Jupyter Notebook - Size: 7.54 MB - Last synced: 5 months ago - Pushed: over 5 years ago - Stars: 0 - Forks: 1

faridrama123/GithubAppMVVM

a sample android app using GitHub API, with Android Architecture + Design Pattern MVVM

Language: Kotlin - Size: 659 KB - Last synced: 5 months ago - Pushed: almost 3 years ago - Stars: 0 - Forks: 0

swarrot/SwarrotBundle

A symfony bundle for swarrot integration

Language: PHP - Size: 358 KB - Last synced: 10 days ago - Pushed: 5 months ago - Stars: 90 - Forks: 59

davidcampos/kafka-spark-flink-example

Kafka streaming with Spark and Flink example

Language: Java - Size: 15.6 KB - Last synced: 3 months ago - Pushed: 11 months ago - Stars: 26 - Forks: 25

raghav-chandra/MBQ

An intelligent queue to serve Parallel and Sequential processing requests of items.

Language: Java - Size: 314 KB - Last synced: 6 months ago - Pushed: almost 2 years ago - Stars: 0 - Forks: 0

Bhumeet10/SQL-project

Project Snapshot: Making Consumer Goods Data Work! 🚀 In my Consumer Goods project, I used tools like SQL and Power BI to understand data easily. I turned complex info into simple pictures and videos with PowerPoint and Clipchamp. The goal? Help our team make smarter decisions. Thanks, Codebasics, for this data adventure!

Size: 0 Bytes - Last synced: 6 months ago - Pushed: 6 months ago - Stars: 0 - Forks: 0

saboye/Real-Time-Data-Streaming-Pipeline

A real-time streaming pipeline streams live tweets data from Twitter and ingests the data to the Apache Kafka clusters as a topic, and consumers consume the hashtag tweets as a message.

Language: Jupyter Notebook - Size: 111 KB - Last synced: 6 months ago - Pushed: over 2 years ago - Stars: 1 - Forks: 0

oleksiivelychko/go-consumer

Consumer service handles messages from third-party channel.

Language: Go - Size: 2.05 MB - Last synced: 4 months ago - Pushed: 11 months ago - Stars: 0 - Forks: 0

prakash2903/ConsumerSegmentation

Kmeans Clustering

Language: R - Size: 2.93 KB - Last synced: about 2 months ago - Pushed: 10 months ago - Stars: 0 - Forks: 0

asahaf/rabbitleap

Simple RabbitMQ consuming framework

Language: Python - Size: 74.2 KB - Last synced: about 1 month ago - Pushed: about 3 years ago - Stars: 1 - Forks: 0

Valbou/Python_API_Consumer

REST API Consumer

Language: Python - Size: 119 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 4 - Forks: 0

bigpe/channels-simplify

Very simple prototyping of your complex websockets

Language: Python - Size: 48.8 KB - Last synced: 11 days ago - Pushed: almost 2 years ago - Stars: 4 - Forks: 0

JorgeGarciaIrazabal/senv

Senv (Super Environment) is a tool to simplify dependency management, packaging, distribution, testing, and consumption of your applications and libraries.

Language: Python - Size: 738 KB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 5 - Forks: 0

first-digital-finance/pyrmq

Python with RabbitMQ—simplified so you won't have to.

Language: Python - Size: 129 KB - Last synced: 14 days ago - Pushed: 14 days ago - Stars: 18 - Forks: 7

Apurva0109/Training

Training Repository -Implementing Java 8 features - Used Predefined Functional Interfaces(Predicate, Function, Consumer, Supplier) and Lambda Expression

Language: Java - Size: 23.4 KB - Last synced: 6 months ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

GokGokalp/MetroBus

Lightweight messaging wrapper of MassTransit

Language: C# - Size: 69.3 KB - Last synced: 5 days ago - Pushed: over 3 years ago - Stars: 72 - Forks: 22

FINTLabs/fint-core-consumer-okonomi-regnskap

Language: Java - Size: 171 KB - Last synced: about 2 months ago - Pushed: 5 months ago - Stars: 0 - Forks: 0

osskit/dafka-consumer

Dockerized Kafka consumer

Language: Java - Size: 15.8 MB - Last synced: 30 days ago - Pushed: about 1 month ago - Stars: 8 - Forks: 2

graciousagency/interconnect-magento1 📦

Webhook module for Magento1 that channels data to the Gracious Interconnect webservice which in turn formats and proxies the data to connected consumer services

Language: PHP - Size: 90.8 KB - Last synced: 3 months ago - Pushed: about 3 years ago - Stars: 2 - Forks: 0

kylemocode/ConsumerX

Priority consumer powered by RxJS 🔥

Language: TypeScript - Size: 162 KB - Last synced: about 1 month ago - Pushed: over 3 years ago - Stars: 8 - Forks: 2

KnowHowSpringBoot/quickstart-amqp-consuming-hello

Minimal Spring Boot based sample of AMQP consumer app.

Language: Java - Size: 180 KB - Last synced: about 2 months ago - Pushed: 3 months ago - Stars: 1 - Forks: 0

aaron-creator/Java_Functional_Programming

Examples for learning Streams, functional ptogramming with Java8.

Language: Java - Size: 39.1 KB - Last synced: 7 months ago - Pushed: 7 months ago - Stars: 0 - Forks: 0

abitofhelp/producerconsumer

An implementation of the classic producer-consumer pattern using Go, goroutines, WaitGroups, and a channel.

Language: Go - Size: 15.6 KB - Last synced: about 1 month ago - Pushed: over 5 years ago - Stars: 1 - Forks: 0

microlinkhq/queue

The high resilient queue for processing URLs.

Language: JavaScript - Size: 124 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 10 - Forks: 3

andrewinci/Insulator 📦

A client UI to inspect Kafka topics, consume, produce and much more

Language: Kotlin - Size: 29.6 MB - Last synced: about 2 months ago - Pushed: about 1 year ago - Stars: 57 - Forks: 9

carloshenriquefs/business-ms

:white_check_mark: - Microservices na prática com Java Spring

Language: Java - Size: 92.8 KB - Last synced: 7 months ago - Pushed: 7 months ago - Stars: 0 - Forks: 0

graviton57/AndroidProducerConsumer

ProducerConsumer android app

Language: Java - Size: 462 KB - Last synced: 8 months ago - Pushed: about 7 years ago - Stars: 1 - Forks: 0

lelikptz/async-consumer

Асинхронный php consumer реализованный с помощью Fiber

Language: PHP - Size: 104 KB - Last synced: 2 months ago - Pushed: 7 months ago - Stars: 0 - Forks: 0

Qihoo360/qbusbridge

The Apache Kafka Client SDK

Language: C++ - Size: 701 KB - Last synced: about 1 month ago - Pushed: 4 months ago - Stars: 289 - Forks: 72

jorgermduarte/csharp-kafka-project

Language: C# - Size: 230 KB - Last synced: 5 days ago - Pushed: 8 months ago - Stars: 1 - Forks: 0

Nefari0uss/producer-consumer

Producer & Consumer simulation to experiment and learn threading.

Language: C - Size: 8.79 KB - Last synced: 8 months ago - Pushed: over 7 years ago - Stars: 3 - Forks: 3

DeepSchneider/java-tricks

Some useful & interesting Java snippets

Language: Java - Size: 3.07 MB - Last synced: 8 months ago - Pushed: 8 months ago - Stars: 5 - Forks: 0

ohbus/retail-banking

Consumer Banking Application

Language: Java - Size: 647 KB - Last synced: 8 months ago - Pushed: over 1 year ago - Stars: 34 - Forks: 41

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

Language: Java - Size: 62.5 KB - Last synced: about 1 month ago - Pushed: over 3 years ago - Stars: 26 - Forks: 18

el-moudni-hicham/springcloud-kafka

This repository contains code demonstrating the integration of Spring Cloud services with Apache Kafka for building scalable and resilient applications with event-driven architecture.

Language: Java - Size: 79.1 KB - Last synced: 8 months ago - Pushed: 8 months ago - Stars: 0 - Forks: 0

Malwarebytes/v1gittools 📦

Git Flow Developer tool with VersionOne and Github Integration

Language: Ruby - Size: 220 KB - Last synced: 11 days ago - Pushed: almost 8 years ago - Stars: 2 - Forks: 0

openware/postmaster

Notification Hub for openware stack

Language: Go - Size: 131 KB - Last synced: 23 days ago - Pushed: over 4 years ago - Stars: 14 - Forks: 18

dsperax/poc-consumer-go

Consumer API using golang to connect kafka -> postgres SQL base.

Size: 529 KB - Last synced: 8 months ago - Pushed: 8 months ago - Stars: 2 - Forks: 0

tgrall/redis-streams-in-action

Project that shows how to use ADD/ACK/PENDING/CLAIM and build an error proof streaming application with Redis Streams and SpringData

Language: Java - Size: 3.15 MB - Last synced: about 2 months ago - Pushed: over 1 year ago - Stars: 4 - Forks: 5

dial-once/node-bunnymq

BunnyMQ is an amqp.node wrapper to ease common AMQP usages (RPC, pub/sub, channel/connection handling etc.).

Language: JavaScript - Size: 1.57 MB - Last synced: 26 days ago - Pushed: about 5 years ago - Stars: 19 - Forks: 6

gnuhpc/Kafka-zk-restapi

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

Language: Java - Size: 13.8 MB - Last synced: 7 months ago - Pushed: over 1 year ago - Stars: 124 - Forks: 33

wkennedy/spring-kafka-cloud-events

The spring-kafka-cloud-events library provides utility in order to use the CloudEvents spec in your project that uses Spring-Kafka.

Language: Java - Size: 45.9 KB - Last synced: about 2 months ago - Pushed: over 3 years ago - Stars: 5 - Forks: 3

Shikha-code36/Real-Time-Stock-Price-Tracker-using-Kafka

A real time stock prices tracker using Kafka

Language: Python - Size: 5.86 KB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 0 - Forks: 0

pagarme/sqs-quooler

A complete queue consumer for SQS

Language: JavaScript - Size: 392 KB - Last synced: 26 days ago - Pushed: 8 months ago - Stars: 21 - Forks: 2

Abdulsametileri/cdc-pact-gophercon-2021

How to write CDC test using Pact in Go? 🤔

Language: Go - Size: 837 KB - Last synced: 3 months ago - Pushed: over 2 years ago - Stars: 53 - Forks: 6

ssamparn/java-functional-programming

Learn functional features of Java

Language: Java - Size: 32.2 KB - Last synced: 4 months ago - Pushed: 8 months ago - Stars: 0 - Forks: 0

jhhtaylor/apache-kafka-with-go

Demo showcasing a Go-based application's integration with Apache Kafka. Offers guidance on Kafka setup, topic creation, and producer-consumer operations.

Language: Go - Size: 6.84 KB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 0 - Forks: 0

reiterus/rabbitmq-php-orchestra

RabbitMQ examples with PHP consumers inside Docker

Language: PHP - Size: 255 KB - Last synced: 5 months ago - Pushed: 5 months ago - Stars: 0 - Forks: 0

reiterus/rabbitmq-php

RabbitMQ with PHP Worker and Docker

Language: PHP - Size: 3.91 KB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 0 - Forks: 0

foobaar/kafka-offset-manager

Move Consumer offsets as you please

Language: Kotlin - Size: 74.2 KB - Last synced: 9 months ago - Pushed: over 6 years ago - Stars: 8 - Forks: 12

sverigesradio/nuget-ember-plus-consumer-lib

A base library for creating an EmBER+ consumer. EmBER+ is an open protocol from Lawo, used to control mixer hardware and share state between applications.

Language: C# - Size: 2.04 MB - Last synced: 10 months ago - Pushed: 11 months ago - Stars: 4 - Forks: 0

Shineuptillast/Kafka_practice

Producer and consumer code for real time processing

Language: Python - Size: 324 KB - Last synced: 10 months ago - Pushed: 11 months ago - Stars: 0 - Forks: 0

testillano/json2xml

C++ Converter from Json to XML

Language: C++ - Size: 172 KB - Last synced: 10 months ago - Pushed: 10 months ago - Stars: 9 - Forks: 2

jd78/rabbit

RabbitMQ client helper with extended functionalities for golang

Language: Go - Size: 1.75 MB - Last synced: 10 months ago - Pushed: over 6 years ago - Stars: 0 - Forks: 0

aarontravass/az-queue-consumer

Lightweight Azure Queue Consumer

Language: TypeScript - Size: 361 KB - Last synced: 16 days ago - Pushed: about 2 months ago - Stars: 0 - Forks: 0

amalsalilan/Unicorn-Insights-A-Comprehensive-Data-Analysis-of-Unicorn-Companie

This dataset contains a list of startup companies around the world that have been valued at $1 billion or more

Language: Jupyter Notebook - Size: 7.48 MB - Last synced: 10 months ago - Pushed: over 1 year ago - Stars: 3 - Forks: 0

Cs4r/sample-spring-kafka-producer-consumer Fork of bijukunjummen/sample-spring-kafka-producer-consumer

Sample demonstrating Spring-Kafka project based Producer/Consumers

Language: Java - Size: 57.6 KB - Last synced: 10 months ago - Pushed: almost 7 years ago - Stars: 0 - Forks: 0

alokawi/concurrency-java-8

Concurrency with Java8, CompletableFuture<T>, Supplier<T>, Consumer<T>

Language: Java - Size: 2.93 KB - Last synced: 10 months ago - Pushed: about 7 years ago - Stars: 0 - Forks: 0

BBC-Data-Unit/onsbasket2010s

Tablets to smart speakers: The 2010s in spending

Size: 167 KB - Last synced: 10 months ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0

BBC-Data-Unit/marmite-row

Marmite row: Shoppers braced for food price hike

Size: 48.8 KB - Last synced: 10 months ago - Pushed: over 7 years ago - Stars: 0 - Forks: 0

BBC-Data-Unit/christmas-dinner

Is Christmas getting cheaper, or more expensive?

Size: 323 KB - Last synced: 10 months ago - Pushed: over 7 years ago - Stars: 2 - Forks: 3