kafka

Zookeeper, Kafka server, and Kafka consumer fixtures for Pytest

https://shaynelussier.com/projects/tennis-streaming

Recursos asociados al prototipo para el proyecto de grado de la Especialización en Ingeniería de Software de la Universidad Distrital.

Semaphore: a system of sending messages by holding the arms or two flags or poles in certain positions according to an alphabetic code.

FastAPI that reads rss feeds from magazines, consolidates and broadcast them to pub/sub and clients.

⛓️ Combination of asyncapi(documentation) & socketio pub/sub using aiokafka as the client manager multinode backend services. Docs https://arieutils.gitlab.io/aiosox/

App that takes real time open source crash data from NYC Open Data and visualises it on a map.

A scalable image classifier using Kafka and GCP's PubSub

This project is a realtime streaming data collection system based on kafka and spark.

Implementing a Pub/Sub messaging system, in the vein of RabbitMQ, Apache Kafka.

This is my take on 'get tweeter stream, send it over to Apache Kafka as JSON objects, receive it in Apache Spark and process the stream'

A set of tools analyzing Kubernetes and OpenShift Events

An Apache Kafka eating Python stream analyzer for OpenShift Events...