Awesome GitHub RepositoriesKafka

goim

JavaTutorial is a specialized knowledge base and set of study guides focused on backend engineering, the Java ecosystem, distributed systems, and database internals. It serves as a technical reference for engineers, providing structured learning paths and curated content designed for Java backend developer interview preparation. The resource distinguishes itself through deep-dive analyses of internal mechanics, including JVM memory management, garbage collection algorithms, and the internal architecture of the Spring Framework. It provides detailed studies on database internals specifically f

Materialize is a streaming SQL database that continuously ingests live data from sources such as Kafka, Redpanda, PostgreSQL, and MySQL, and incrementally maintains materialized views. It provides a PostgreSQL-compatible query engine that accepts standard SQL over the PostgreSQL wire protocol, enabling any existing SQL client or BI tool to query real-time data. The system also includes a Model Context Protocol (MCP) server that exposes live materialized view data to AI agents, providing fresh context without polling. Materialize distinguishes itself through its ability to offer configurable c

Kafkacat este o suită de utilitare de linie de comandă pentru interacțiunea cu clusterele Apache Kafka. Oferă un binar non-JVM pentru producerea și consumarea mesajelor, inspectarea metadatelor clusterului și depanarea protocolului Kafka prin terminal. Instrumentul funcționează ca un producător și consumator capabil să trimită date din fișiere sau input standard și să citească mesaje din topicuri și partiții specifice. Include un inspector de metadate pentru a prelua starea clusterului și configurațiile partițiilor în text simplu sau JSON, precum și un depanator de protocol pentru inspectarea offset-urilor mesajelor, timestamp-urilor și payload-urilor binare. Proiectul acoperă deserializarea datelor folosind scheme sau decodoare primitive și interogarea bazată pe offset pentru a prelua date de la timestamp-uri precise. De asemenea, oferă utilitare de simulare pentru a rula brokeri efemeri în memorie pentru testarea integrării și benchmarking-ul performanței.

Burrow is a monitoring and alerting service for Kafka clusters. It tracks consumer group lag by evaluating committed offsets and identifying the gap between produced and consumed messages. The system calculates processing delays using a sliding-window offset evaluation and monitors overall cluster health. When consumer group conditions meet predefined thresholds, it triggers notifications to external services via email or webhooks. The service provides HTTP endpoints for querying broker information and consumer group status, allowing external tools to poll for system health and performance m