kafka helper library

High abstraction wrapper for Golang Rabbit MQ Client

A Go service that consumes order events from Kafka (Redpanda), validates them, stores them in PostgreSQL, and serves them via an HTTP API and a simple web UI. It includes an in‑memory cache with warm‑up, a DLQ for invalid/failed messages, a test data producer (valid/invalid), Prometheus metrics, and OpenTelemetry tracing.

hobom event processor

SQS DLQ Replayer

A CLI-first dead letter autopsy engine. Analyzes DLQ payloads, groups failure signatures deterministically, and reconstructs execution timelines locally without any SaaS overhead.

Persistent dead-letter queue for Go — disk-backed, automatic retries with exponential backoff, crash-safe replay

RideSync is a high-performance, microservices-based backend system designed to power modern ride-sharing and carpooling platforms. Built with Go and TypeScript, the platform orchestrates complex logistics workflows, including real-time driver matching, geospatial route optimization, and automated payment processing.

A production-ready Go library for Kafka client and consumer functionality built on top of confluent-kafka-go. This library provides enterprise-grade features including intelligent batch processing, idempotency guarantees, key-based grouping, and automatic pressure management.

Dumping DLQ implementation for queue package.

FlashSend is a Go-based distributed notification system that delivers SMS, Email, and scheduled notifications using RabbitMQ asynchronous workers. It implements DB-backed scheduling, exponential retries with dead-letter queues (DLQ), and horizontal worker scaling to handle traffic spikes reliably.