awesome-repositories.com
المدونة
awesome-repositories.com

اكتشف أفضل مستودعات المصادر المفتوحة باستخدام بحث مدعوم بالذكاء الاصطناعي.

استكشفعمليات بحث منسقةبدائل مفتوحة المصدربرمجيات ذاتية الاستضافةالمدونةخريطة الموقع
المشروعحولكيفية ترتيب النتائجالصحافةخادم MCP
قانونيالخصوصيةالشروط
© 2026 Bringes Technology SRL·VAT RO45896025·hello@awesome-repositories.com
·
Jeffail avatar

Jeffail/benthos

0
View on GitHub↗
docs.redpanda.com/connect/home↗

Benthos

Benthos is a declarative stream processor and data integration pipeline used to route, transform, and filter information between disparate services. It functions as an at-least-once message broker and change data capture engine, using a transaction model to guarantee message delivery despite system crashes or server faults.

The system is defined by an observability-first approach, featuring built-in HTTP health probes, performance metrics export, and distributed request flow tracing. It utilizes a plugin architecture that allows the core engine to be extended with custom binaries for new input and output connectors.

The project manages data flow through a single configuration file to define pipelines. These pipelines support real-time database change events, buffered stream processing, and data transformation using a specialized mapping language.

بحث بالذكاء الاصطناعي

استكشف المزيد من المستودعات الرائعة

صف ما تحتاجه بلغة بسيطة — وسيقوم الذكاء الاصطناعي بترتيب آلاف المشاريع مفتوحة المصدر المنسقة حسب الصلة.

Start searching with AI

Features

  • Data Streaming - Provides a declarative system for routing and moving real-time data streams between disparate services.
  • Change Data Capture - Streams real-time database change events from supported databases into downstream processing pipelines.
  • Data Pipeline Configurations - Uses a single declarative configuration file to define the connection of diverse data sources and sinks.
  • Data Stream Processors - Offers a declarative stream processing architecture to route, transform, and filter real-time data flows.
  • Message Brokers - Acts as a data transport system that guarantees message delivery via a transaction model.
  • Stream Transformations - Modifies, enriches, and filters information in transit as it moves from a source to a destination.
  • At-Least-Once Delivery Guarantees - Ensures messages are delivered at least once using a transaction model that survives system crashes and faults.
  • Data Mapping Languages - Provides a specialized mapping language to filter and enrich data payloads as they move through the pipeline.
  • Data Integration - Facilitates the connection and exchange of information between disparate software systems and data sources.
  • Data Pipelines - Provides composable stages for moving and transforming data between disparate services.
  • Stream Buffering Pipelines - Utilizes internal buffers to decouple source ingestion from destination output across pipeline stages.
  • Plugin Architectures - Supports integrating custom plugins to add specialized capabilities and new behaviors to the core engine.
  • Plugin-Based Architectures - Allows the core engine to be extended with custom binaries for new input and output connectors.
  • End-to-End Message Tracing - Provides telemetry traces to visualize the end-to-end path of data as it moves through processing pipelines.
  • Pipeline Health Monitors - Tracks the operational health and performance of data streams through telemetry traces and monitoring backends.
  • Internal Telemetry Monitors - Exposes internal health and performance metrics via HTTP endpoints and tracing for external monitoring.
  • Observability Tools - Includes built-in HTTP health checks, performance metrics, and distributed tracing for operational monitoring.
  • Data Processing and Streams - Stream processing engine.
  • Streaming Libraries - High-performance message streaming service for transformations.
  • Messaging Systems - Message stream bridge between various protocols.
8,681 نجوم·944 تفرعات·Go·2 مشاهدات

سجل النجوم

مخطط تاريخ النجوم لـ jeffail/benthosمخطط تاريخ النجوم لـ jeffail/benthos

الأسئلة الشائعة

ما هي وظيفة jeffail/benthos؟

Benthos is a declarative stream processor and data integration pipeline used to route, transform, and filter information between disparate services. It functions as an at-least-once message broker and change data capture engine, using a transaction model to guarantee message delivery despite system crashes or server faults.

ما هي الميزات الرئيسية لـ jeffail/benthos؟

الميزات الرئيسية لـ jeffail/benthos هي: Data Streaming, Change Data Capture, Data Pipeline Configurations, Data Stream Processors, Message Brokers, Stream Transformations, At-Least-Once Delivery Guarantees, Data Mapping Languages.

ما هي البدائل مفتوحة المصدر لـ jeffail/benthos؟

تشمل البدائل مفتوحة المصدر لـ jeffail/benthos: redpanda-data/connect — Connect is a Kafka data integration platform and stream processing engine used to build declarative pipelines that… benthosdev/benthos — Benthos is a stream processing engine and data integration pipeline used for routing, transforming, and connecting… vectordotdev/vector — Vector is a high-performance observability data pipeline designed to collect, transform, and route logs, metrics, and… vonng/ddia — This project serves as a comprehensive technical reference for the architecture and design of data-intensive… uptrace/uptrace — Uptrace is an OpenTelemetry-based observability platform designed to collect, store, and analyze distributed traces,… risingwavelabs/risingwave — RisingWave is a cloud-native streaming database and real-time analytics engine that uses standard SQL to process…

بدائل مفتوحة المصدر لـ Benthos

مشاريع مفتوحة المصدر مشابهة، مرتبة حسب عدد الميزات المشتركة مع Benthos.
  • redpanda-data/connectالصورة الرمزية لـ redpanda-data

    redpanda-data/connect

    8,681عرض على GitHub↗

    Connect is a Kafka data integration platform and stream processing engine used to build declarative pipelines that move and transform messages between Kafka topics and external sources. It functions as a Kafka Connect framework and a change data capture tool, streaming real-time database modifications to synchronize data across distributed environments. The project differentiates itself through a dedicated mapping language for mutating and reshaping message payloads and the ability to execute custom processing logic within a sandboxed WebAssembly runtime. It also provides an observability pip

    Goamqpcqrsdata-engineering
    عرض على GitHub↗8,681
  • benthosdev/benthosالصورة الرمزية لـ benthosdev

    benthosdev/benthos

    8,681عرض على GitHub↗

    Benthos is a stream processing engine and data integration pipeline used for routing, transforming, and connecting data streams between diverse sources and sinks. It functions as event routing middleware and a change data capture tool, streaming real-time database modifications as discrete events for downstream processing. The system utilizes a declarative pipeline configuration, where data flow and processing logic are defined in a single static file. It features a specialized domain-specific language for mapping, filtering, and enriching data payloads, allowing for complex transformations w

    Go
    عرض على GitHub↗8,681
  • vectordotdev/vectorالصورة الرمزية لـ vectordotdev

    vectordotdev/vector

    22,071عرض على GitHub↗

    Vector is a high-performance observability data pipeline designed to collect, transform, and route logs, metrics, and traces across distributed infrastructure. It functions as a modular engine that decouples data ingestion from processing and transmission, utilizing a component-based architecture to connect diverse sources to multiple destinations. The project distinguishes itself through a focus on reliability and flow control. It implements backpressure-aware data movement to prevent data loss during traffic spikes and utilizes disk-backed event buffering to ensure durability during network

    Rusteventsforwarderhacktoberfest
    عرض على GitHub↗22,071
  • vonng/ddiaالصورة الرمزية لـ Vonng

    Vonng/ddia

    22,648عرض على GitHub↗

    This project serves as a comprehensive technical reference for the architecture and design of data-intensive applications. It provides a structured analysis of the fundamental principles required to build reliable, scalable, and maintainable software systems, covering the core trade-offs inherent in modern data infrastructure. The repository explores the mechanics of distributed data management, including strategies for replication, partitioning, and achieving consensus across multiple nodes. It details the design of storage engines, indexing techniques, and transaction management models, whi

    Pythonbookdatabaseddia
    عرض على GitHub↗22,648
عرض جميع البدائل الـ 30 لـ Benthos→