Awesome GitHub RepositoriesAvro Decoding

fq es un procesador de datos binarios de línea de comandos utilizado para decodificar, transformar y analizar flujos de bytes crudos y datos a nivel de bit en formatos estructurados. Funciona como un motor de consulta binario funcional que permite filtrar y mapear estructuras binarias, así como un convertidor que traduce blobs binarios complejos y formatos de archivo propietarios a JSON, YAML o XML estándar. La herramienta se distingue como un manipulador de bits de bajo nivel capaz de realizar cortes a nivel de bit, operaciones a nivel de bit y hashing criptográfico en archivos crudos. También sirve como analizador de protocolos de red con la capacidad de reensamblar flujos TCP fragmentados y descifrar tráfico TLS para inspección a nivel de aplicación. El proyecto cubre amplias capacidades en el análisis binario y la transformación de datos, incluyendo soporte para definiciones de decodificadores personalizados y una amplia gama de formatos especializados como Mach-O, ASN1 BER y Avro OCF. Proporciona utilidades para la búsqueda en árboles binarios, decodificación de texto estructurado y serialización bidireccional entre formatos binarios y de texto. Los usuarios pueden interactuar con el sistema a través de una interfaz de línea de comandos y un REPL interactivo para pruebas de consulta en tiempo real.

RisingWave is a cloud-native streaming database and real-time analytics engine that uses standard SQL to process continuous data streams. It functions as a streaming data lakehouse, combining the capabilities of a streaming SQL database with a platform that integrates streaming ingestion with open table formats. The system is distinguished by its use of the PostgreSQL wire protocol, allowing it to integrate with existing SQL tools and drivers. It employs a decoupled compute and storage architecture, persisting streaming state and materialized views in cloud object storage to enable independen

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

Apache Hive is a SQL-on-Hadoop data warehouse that enables querying and managing petabytes of data stored in distributed storage such as HDFS and cloud storage services. It provides a familiar SQL interface for batch analytics and reporting, supported by a core set of components including the HiveServer2 Thrift service for remote query execution, the Hive Metastore Service for central metadata management, the Hive ACID Transaction Engine for concurrent read-write operations, and the Hive LLAP Interactive Engine for low-latency analytical processing. The WebHCat REST API offers an HTTP interfac

CloudEvents is an open specification for describing event data in a common format across cloud platforms and services. It defines a standard structure and set of metadata attributes for events, enabling interoperability across different systems so producers and consumers can exchange events without custom translation. The specification provides a protocol-agnostic serialization framework that maps CloudEvents attributes and payloads to multiple serialization formats including JSON, Avro, and Protobuf, and defines transport bindings for mapping events onto protocols like HTTP, AMQP, Kafka, MQTT

kcat es un cliente de interfaz de línea de comandos para Apache Kafka utilizado para producir, consumir y depurar mensajes utilizando el protocolo nativo. Proporciona un conjunto de herramientas para interactuar con clusters de Kafka, incluyendo un depurador de protocolos para inspeccionar metadatos del cluster y un gestor de transacciones para manejar lotes de mensajes atómicos. El proyecto cuenta con un decodificador de esquemas Avro especializado que convierte mensajes codificados en binario en JSON legible por humanos mediante la integración con registros de esquemas remotos o archivos locales. Además, incluye un simulador en memoria que permite probar la lógica del productor y consumidor simulando el comportamiento efímero del broker sin requerir infraestructura externa. El conjunto de herramientas cubre una amplia gama de operaciones de mensajería, incluyendo soporte para grupos de consumidores balanceados, búsqueda de offsets basada en marcas de tiempo y streaming de datos transaccionales desde la entrada estándar. También proporciona utilidades para la configuración de seguridad de la conexión y la inspección de metadatos del cluster.

Racket es un lenguaje de programación de propósito general y multiparadigma de la familia Lisp, diseñado para la creación de lenguajes. Funciona como un banco de trabajo de lenguajes, proporcionando una plataforma para diseñar e implementar lenguajes de programación personalizados a través de un sistema flexible de macros y módulos. El sistema se distingue por ofrecer una suite integral para la ingeniería de semántica, permitiendo la construcción de subconjuntos de lenguajes especializados y capas educativas. Incluye herramientas para el diseño de lenguajes personalizados, como la generación de lexers y parsers, así como la capacidad de definir reglas de expansión de módulos y selección dinámica de lenguaje en tiempo de lectura. El proyecto proporciona un entorno de desarrollo integrado con un editor incorporado, depurador visual y un gestor de paquetes de software. Su superficie de capacidades se extiende a una biblioteca estándar de propósito general que cubre renderizado de gráficos 2D, procesamiento de datos binarios, integración con SQL y bases de datos deductivas, y la construcción de interfaces gráficas de usuario. El entorno admite la compilación de código fuente en archivos ejecutables independientes para su distribución.

Arroyo is a high-performance stream processing platform built in Rust. It executes continuous SQL queries on streaming data with event-time semantics, enabling accurate windowed aggregations, joins, and stateful computations on unbounded event streams. The platform uses native Rust execution for high throughput and low latency, with periodic checkpointing for exactly-once fault tolerance and horizontal scaling across distributed workers. The system integrates deeply with Kafka for reading and writing topics with exactly-once delivery and supports change data capture (CDC) from MySQL and Postg