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
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
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
kpmeen/kafka-workshop
Kafka Workhop demo application. Showing producers, consumers and stream processing.
Last synced at: over 2 years ago - Stars: 0 - Forks: 3
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
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
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
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
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
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
TomPlese/kafka-consumer-java-with-spring-boot
Last synced at: over 2 years ago - Stars: 2 - Forks: 1
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
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
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