kafka

Spring template for a REST service designed with Hexagonal architecture

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/

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..

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.

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

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.

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

Use Websocket and HTTP to send and receive messages to Kafka

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

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

A simple kafka / docker-compose mockup stack

Example on how access a Kafka cluster deployment in OpenShift

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

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

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

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

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

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

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.