An open API service providing repository metadata for many open source software ecosystems.

gitlab.com topics: kafka

karolinepauls/pytest-kafka

Zookeeper, Kafka server, and Kafka consumer fixtures for Pytest

Last synced at: 2 months ago - Stars: 0 - Forks: 6

eemj/image-processor-archive

An API and a consumer responsible for converting images to other formats

Last synced at: about 1 year ago - Stars: 0 - Forks: 0

charlycoste/kafkaconsumeriterator.php

Last synced at: about 1 year ago - Stars: 0 - Forks: 1

xavki/tutoriels-kafka

Découvrez la formation & tutos Kafka gratuitement : https://www.youtube.com/playlist?list=PLn6POgpklwWreX6DssE1tdt9O5rJe0naK

Last synced at: almost 2 years ago - Stars: 0 - Forks: 2

mrbardia72/can2j

Kanduj , in Tabari and Talshi languages , is called a room where harvested rice is kept until threshing time. Kenduj is a room for storing rice clusters, which is placed on four or six bases. In the past, Kendujs were called Galipos

Last synced at: almost 2 years ago - Stars: 0 - Forks: 0

osp-silver/oss/movex-cdc

Change data capture on Oracle databases + transfer of change events to Kafka

Last synced at: almost 2 years ago - Stars: 2 - Forks: 0

ShowMeYourCodeYouTube/kafka-producer-consumer

Kafka producer and consumer samples using Java and Kotlin. There are two implementations: a simple one and the second using Apache Avro in both languages.

Last synced at: about 2 years ago - Stars: 1 - Forks: 2

kpmeen/kafka-websocket-proxy

WebSocket proxy that allows clients to produce and consume messages from topics in Apache Kafka. Documentation can be found at https://kpmeen.gitlab.io/kafka-websocket-proxy/

Last synced at: about 2 years ago - Stars: 4 - Forks: 5

opencity-labs/krun

Krun reads events from a Kafka topic and run a system command passing the read event to the stdin of the command. The command can be a bash script or anything else that can manage a stdin.

Last synced at: about 2 years ago - Stars: 0 - Forks: 0

joelwking/semaphore

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

Last synced at: about 2 years ago - Stars: 1 - Forks: 0

dvvm.silva/fintech

iremos simular um pequeno sistema de solicitação de cartões. usando arquitetura de microsserviços.

Last synced at: about 2 years ago - Stars: 0 - Forks: 0

robertoshimizu/rss-parser-using-fastapi

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

Last synced at: about 2 years ago - Stars: 1 - Forks: 1

Andr1500/elk_nginx_kafka_grafana

ELK stack + Beats + NGINX + Apache Kafka + Grafana on AWS configured with Ansible

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

arieutils/aiosox

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

Last synced at: 3 months ago - Stars: 0 - Forks: 0

NithinSS/activity-watcher-aggregator

A scalable activity aggregator for Activity Watch(https://activitywatch.net/) using Apache Kafka, Springboot and AngularJS.

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

sgnd/kafka-ansible

Setup Kafka with Ansible

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

xuanluo2016/payment-channel-performance

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

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

rgnu/kafka-serf

Last synced at: over 2 years ago - Stars: 0 - Forks: 2

kpmeen/kafka-workshop

Kafka Workhop demo application. Showing producers, consumers and stream processing.

Last synced at: over 2 years ago - Stars: 0 - Forks: 3

cncws-playground/aiokafka-quickstart

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

kpmeen/docker-kafka-backends

Different setups and scripts for running Confluent Kafka and Zookeeper in docker containers.

Last synced at: over 2 years ago - Stars: 0 - Forks: 3

HariSekhon/DevOps-Bash-tools

1000+ DevOps Bash Scripts - AWS, GCP, Kubernetes, Docker, CI/CD, APIs, SQL, PostgreSQL, MySQL, Hive, Impala, Kafka, Hadoop, Jenkins, GitHub, GitLab, BitBucket, Azure DevOps, TeamCity, Spotify, MP3, LDAP, Code/Build Linting, pkg mgmt for Linux, Mac, Python, Perl, Ruby, NodeJS, Golang, Advanced dotfiles: .bashrc, .vimrc, .gitconfig, .screenrc, tmux..

Last synced at: about 2 years ago - Stars: 18 - Forks: 15

goern/tweest

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'

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

r1chjames/kafka-producer-consumer

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

kpmeen/kafka-topic-admin-cli

CLI tool to manage, edit and create topic configurations in Kafka.

Last synced at: over 2 years ago - Stars: 0 - Forks: 1

samko635/kafka-sandpit

Last synced at: over 2 years ago - Stars: 1 - Forks: 0

vuthanhtb.dev/kafka-springboot

Last synced at: almost 3 years ago - Stars: 0 - Forks: 0

hino-hatake/task-manager

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

dcs3spp/blazormotiondetectionlistener

Listen to object detections from message queue associated with a webcam and display on dashboard

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

therackio/big-data/helper-images/confluent-kafka-builder-5-arm64

Extends the Java buildtools image by compiling needed Confluent libraries for other Confluent Kafka tools,

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

cecilegltslmcs/ingestion_hadoop_mapreduce

This repo contains the main scripts realised in order to ingest data with Apache Kafka and realise MapReduce operations with Python. You can also find other documentations about the detailled pipeline and the relationnal database.

Last synced at: almost 3 years ago - Stars: 0 - Forks: 0

arise-biodiversity/biocloud/docker-compose-biocloud-cdc

Store and find Arise data: change data capture

Last synced at: almost 3 years ago - Stars: 0 - Forks: 0

ddimitrakop0/kafka-producer-consumer-demo

Demo project to learn Kafka messaging, using the Spring framework.

Last synced at: about 2 years ago - Stars: 0 - Forks: 0

gatti88/eventd

Last synced at: about 2 years ago - Stars: 0 - Forks: 0

Bborg/visualising-real-time-nyc-crash-data-python

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

Last synced at: almost 3 years ago - Stars: 0 - Forks: 0

awesome_o/kafka

A simple kafka / docker-compose mockup stack

Last synced at: almost 3 years ago - Stars: 2 - Forks: 2

morenopinamanueljesus/nifi

Last synced at: almost 3 years ago - Stars: 0 - Forks: 0

arajpaul/arajpaul.web.api

.NET 5 Web API with RabbitMQ and Kafka Implementations

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

openshift-samples/kafka-external-client

Example on how access a Kafka cluster deployment in OpenShift

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

swissbib/linked/lsb-baseline

Kafka streams application which extracts different entities out of bibliographic resources (in MARC-XML) and transforms them to JSON-LD documents

Last synced at: over 2 years ago - Stars: 0 - Forks: 1

swissbib/eventhub-doku

https://swissbib.gitlab.io/eventhub-doku/

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

lamoboos223/appointments-booking

Last synced at: over 2 years ago - Stars: 1 - Forks: 1

iok8s/collector

REST API that collects data via a PUSH request and publish it to a Kafka clúster.

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

lamoboos223/monitoring

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

dynajoob/microprofile

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

TomPlese/kafka-consumer-java-with-spring-boot

Last synced at: over 2 years ago - Stars: 2 - Forks: 1

TomPlese/kafka-simple-example-python

Last synced at: over 2 years ago - Stars: 1 - Forks: 0

TomPlese/kafka-producer-java-with-spring-boot

Last synced at: over 2 years ago - Stars: 2 - Forks: 1

therackio/big-data/applications/apache-kafka/confluent-kafka-aio-5-arm64

"All In One" application image for Confluent Platform using only Confluent Community components, setup generally as described here: https://docs.confluent.io/current/installation/installing_cp/zip-tar.html#prod-kafka-cli-install

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

migandr/kafka-twitter

For learning purposes. A Kafka Streaming system that extracts tweets and ingest them on ElasticSearch.

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

momentonau/kafka-connect-zeebe

https://github.com/zeebe-io/kafka-connect-zeebe.git

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

contributions1/slim-kafka

Simplified instantiation of Kafka's consumer and producer, built on top of node-rdkafka.

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

rychly-edu/theses/dist-forensic-digital-data-repo

Distributed storage for digital forensic data with data/metadata repository, API for queries and incoming/outgoing data, indexing, plug-in system for yet unsupported data-types, etc.

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

dctx/rapidpass/rapidpass-backend

Backend Services for the RapidPass System

Last synced at: over 2 years ago - Stars: 1 - Forks: 1

vchekan/wireshark-kafka

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

tsjnsn/kafka-regex-authorizer

An authorizer plugin for Kafka which checks principal names against a regex defined in the ACLs

Last synced at: about 2 years ago - Stars: 0 - Forks: 0

jakecowton/vector_ai_challenge

A scalable image classifier using Kafka and GCP's PubSub

Last synced at: 11 months ago - Stars: 0 - Forks: 0

swissbib/linked/kafka-producer-elasticsearch

A micro service to scroll a specified elasticsearch index with a query and putting every returned document as is into a kafka topic.

Last synced at: over 2 years ago - Stars: 0 - Forks: 1

swissbib/linked/linking/wikidata-import-filter

Mirco service to filter unused wikidata messages.

Last synced at: over 2 years ago - Stars: 0 - Forks: 1

swissbib/linked/kafka-consumer-elasticsearch

Consumer to read messages from kafka topics and bulk indexing, updating or deleting in elasticsearch.

Last synced at: over 2 years ago - Stars: 0 - Forks: 1

swissbib/linked/kafka-consumer-files

Mircoservice that writes messages into files (with compression)

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

hino-hatake/scheduled-task

Pikachu knows what he does

Last synced at: over 2 years ago - Stars: 0 - Forks: 1

rodrigo42/spark_studies

Learning Spark in java/scala

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

proticity/cloud/java-modern-gradle-plugin

A Gradle plugin which pre-configures Java projects with an assortment of plugins and managed dependency versions for modern Java development.

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

hino-hatake/fuck-kafka

do what the fuck with kafka

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

vkrava4-hands-on/avro-converter-demo

Demo project for Avro Converter Java library which enables conversion of Apache Avro object into popular data formats: JSON, XML, etc

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

amit-kamat/Pub-Sub-Docker

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

Last synced at: over 2 years ago - Stars: 0 - Forks: 2

oridonner/kafka-twitter-rdbms-pipeline

Different Kafka Twitter RDBMS pipeline deployments

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

oridonner/kafka-twitter-source-connector

Kafka Twitter Source Connector

Last synced at: over 2 years ago - Stars: 0 - Forks: 2

dcx-brokers/kafka/kafka-producer

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

dcx-brokers/kafka/kafka-consumer

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

kpmeen/multimodule-akka-streams-kafka.g8

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

gt8/open-source/elixir/eidetic-eventstore-subscriber-kafka

Eidetic EventStore Subscriber - Kafka

Last synced at: over 2 years ago - Stars: 1 - Forks: 0

openshift-analytics/raw-events-switchyard

A set of tools analyzing Kubernetes and OpenShift Events

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

openshift-analytics/event-stream-analytics

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

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

goern/deployment-series-server

This is a visualization of OpenShift Deployment Events

Last synced at: over 2 years ago - Stars: 0 - Forks: 0

ccis-irad/spark-analytics

Analytics developed for platform

Last synced at: over 2 years ago - Stars: 0 - Forks: 1