A lightweight stream processing library for Go

A Golang client for ksqlDB

Apache Kafka Streams for Golang

ksqldb-go client

k6 extension to output real-time test metrics to a Kafka topic.

Go/Kafka client library for developing event sourcing applications

Rest Api based kafka event producer that supports multiple encoding types including Avro, Json, MessagePack, String & Bytes.

A simple streamlined notification application that uses Kafka to efficiently handle the communication between producers and consumers for seamless notification delivery.

Kafka X-Ray. Generic web frontend to view, search, explore and visualize keys, headers and payloads.

Migration tool for ksqlDB

Simple Apache Kafka dashboard for following streamed messages

Enhanced observability and security framework built to fully prevent DNS exfiltration (C2, tunnelling) with no data loss, supporting killing C2 implants using TC, Netfilter, Sock, BPF_MAPs. Ring Buffers, Running eBPF inside linux kernel and Deep Learning in user space and threat events streaming for dynamic blacklisting of malicious domains.

EventStoreDB-like stream projections on top of Apachi Kafka.

👺 Echo or Gin like kafka API wrapper for kafka-go

simple message queuing system using the Go programming language with Kafka as the underlying message broker

OpenNMS Kafka Producer Enhancer

Youtube Notifier (Telegram Bot) - A real time data processing pipeline

Welcome to the Kafka Data Processing with Go project! This project showcases how to use Apache Kafka in combination with the Go programming language to build a data processing application.

A web crawler & sentiment analysis tool built with Golang and Kafka

Example implementation CSV streaming data as worker service