awesome-repositories.com
Blog
MCP
awesome-repositories.com

Discover the best open-source repositories with AI-powered search.

ExploreCurated searchesOpen-source alternativesSelf-hosted softwareBlogSitemap
ProjectMCP serverAboutHow we rankPress
LegalPrivacyTerms
© 2026 Bringes Technology SRL·VAT RO45896025·hello@awesome-repositories.com
go-mysql-org avatar

go-mysql-org/go-mysql-elasticsearch

0
View on GitHub↗
4,154 stars·796 forks·Go·MIT·12 views

Go Mysql Elasticsearch

This project is a change data capture system and synchronization layer that moves data from MySQL databases into Elasticsearch indices. It functions as a relational-to-document mapper, transforming database tables into searchable documents to enable real-time data integration and full-text search.

The synchronizer differentiates itself by supporting relational data denormalization, which transforms one-to-many database joins into parent-child document structures. It also allows for partitioned table aggregation, using regular expression patterns to group multiple database tables into a single search index.

The system covers comprehensive data mapping and transformation, including field type conversion, schema mapping, and synchronized field filtering. It employs a pipeline-based processing model to decode and merge fields, utilizing both snapshot-based initial loading for baselines and binary log streaming for real-time updates.

Features

  • MySQL to Elasticsearch Synchronizers - Streams records from MySQL databases into Elasticsearch indices to enable real-time full-text search and analytics.
  • Search Index Synchronizers - Maintains real-time consistency between MySQL databases and external Elasticsearch search engine indices.
  • Elasticsearch Integrations - Moves data from MySQL to Elasticsearch in real time to enable fast full text search and complex querying.
  • Change Data Capture Streams - Implements a change data capture stream that reads MySQL binary logs to trigger real-time search index updates.
  • Change Data Capture Systems - Implements a change data capture system that streams database binary logs to maintain real-time search index synchronization.
  • Database Replication Middleware - Acts as a synchronization layer that captures database state changes and broadcasts them to an external search index.
  • Database Schema Mapping - Translates table and column names into specific index and field names using configurable mapping rules.
  • Database-to-Index Mapping - Defines how specific tables or wildcard patterns map to target indices and data types.
  • Real-Time Data Streaming - Streams updates from a database to a search engine to ensure the index reflects the current state of the data.
  • Snapshot-Based Bootstrapping - Performs a full read of existing database tables to establish a baseline before switching to real-time streaming.
  • Relational Search Indexing - Converts relational database tables into searchable documents while maintaining data types and custom field mappings.
  • Relational-to-Document Mapping - Maintains one-to-many database joins by assigning parent identifiers to documents within the search index.
  • Search Index Field Mapping - Translates database column names and types into search index fields using a predefined configuration map.
  • Relational-to-Document Conversions - Transforms normalized MySQL database tables into hierarchical document-based formats for Elasticsearch indexing.
  • Parent-Child Document Structures - Implements relational data denormalization by transforming database joins into parent-child document structures.
  • Indexing Transformation Pipelines - Provides indexing transformation pipelines to cleanse and reshape database records before they are committed to the search index.
  • Field Type Conversions - Changes data formats during synchronization, such as converting comma-separated strings into arrays for improved filtering.
  • Document Processing Pipelines - Passes data through processing nodes to decode JSON or merge fields before the final indexing step.
  • Field Transformations - Renames columns and converts data types to transform strings into arrays or integers into dates during synchronization.
  • Ingest Pipeline Routing - Directs documents through pre-processing pipelines to perform tasks like decoding JSON or merging fields before indexing.
  • One-to-Many Relationship Models - Maintains one-to-many joins by defining parent field properties that keep related documents organized in the index.
  • Table Aggregation Patterns - Uses regular expression patterns to aggregate multiple partitioned database tables into a single search index.
  • Regex Table Aggregation - Captures data from multiple tables matching a regex pattern and combines them into a single search index.
  • Document Processing Pipelines - Provides sequential transformation stages to decode JSON or merge fields before indexing records.
  • Index Document Linking - Links related documents in a search index using parent fields to support one-to-many data joins.

Star history

Star history chart for go-mysql-org/go-mysql-elasticsearchStar history chart for go-mysql-org/go-mysql-elasticsearch

How this analysis was created: This summary and feature list are AI-generated from collected project material and can contain mistakes. Stars, license and language are imported from GitHub. Inclusion does not mean that we have tested or audited this project. Check the source documentation for any feature you depend on. Learn more on our About page.

AI search

Explore more awesome repositories

Describe what you need in plain English — the AI ranks thousands of curated open-source projects by relevance.

Start searching with AI

Frequently asked questions

What does go-mysql-org/go-mysql-elasticsearch do?

This project is a change data capture system and synchronization layer that moves data from MySQL databases into Elasticsearch indices. It functions as a relational-to-document mapper, transforming database tables into searchable documents to enable real-time data integration and full-text search.

What are the main features of go-mysql-org/go-mysql-elasticsearch?

The main features of go-mysql-org/go-mysql-elasticsearch are: MySQL to Elasticsearch Synchronizers, Search Index Synchronizers, Elasticsearch Integrations, Change Data Capture Streams, Change Data Capture Systems, Database Replication Middleware, Database Schema Mapping, Database-to-Index Mapping.

Which projects share features with go-mysql-org/go-mysql-elasticsearch?

Projects with overlapping indexed features include: electric-sql/electric — Electric is a Postgres data synchronization engine and replication proxy designed to enable local-first software. It… rethinkdb/rethinkdb — RethinkDB is a distributed, document-oriented database designed to store and manage JSON-formatted data across… hazelcast/hazelcast — Hazelcast is a distributed data platform that combines an in-memory data grid with a stream processing engine to… vespa-engine/vespa — Vespa is a distributed search engine, vector database, and machine learning ranking engine. It serves as an AI search… zombodb/zombodb — Zombodb is a database extension and relational data indexer that integrates PostgreSQL with Elasticsearch. It provides… delta-io/delta — Delta is a lakehouse table format that brings ACID transactions and data warehouse consistency to large scale data…

Projects sharing features with Go Mysql Elasticsearch

These projects share indexed features with Go Mysql Elasticsearch. Shared tags can include platform or build tooling; verify the primary use case before treating a result as a replacement.
  • electric-sql/electricelectric-sql avatar

    electric-sql/electric

    9,909View on GitHub↗

    Electric is a Postgres data synchronization engine and replication proxy designed to enable local-first software. It replicates data from Postgres databases to client-side stores in real time using logical replication, allowing applications to maintain a local embedded database for offline access and low-latency updates. The system distinguishes itself by using shapes to filter and authorize specific subsets of database rows and columns before streaming them to clients or edge workers. It further supports multi-user collaboration by integrating a conflict-free replicated data type framework t

    Elixircrdtcrdtselixir
    View on GitHub↗9,909
  • rethinkdb/rethinkdbrethinkdb avatar

    rethinkdb/rethinkdb

    26,996View on GitHub↗

    RethinkDB is a distributed, document-oriented database designed to store and manage JSON-formatted data across scalable clusters. It utilizes a custom log-structured storage engine with B-Tree indexing to ensure high-performance disk I/O and data persistence. The system maintains high availability through automatic sharding and replication, employing a primary-replica voting consensus mechanism to handle node failures and ensure consistent cluster operations. A defining characteristic of the platform is its reactive changefeed engine, which allows applications to subscribe to live data update

    C++
    View on GitHub↗26,996
  • hazelcast/hazelcasthazelcast avatar

    hazelcast/hazelcast

    6,570View on GitHub↗

    Hazelcast is a distributed data platform that combines an in-memory data grid with a stream processing engine to support real-time analytics and event-driven applications. It functions as a partitioned, distributed key-value store that replicates data across cluster nodes to provide low-latency access and high availability. The platform also serves as a distributed SQL query engine, allowing users to execute standard SQL statements against both in-memory datasets and external data sources. What distinguishes Hazelcast is its use of a distributed consensus subsystem to maintain strongly consis

    Javabig-datacachingdata-in-motion
    View on GitHub↗6,570
  • vespa-engine/vespavespa-engine avatar

    vespa-engine/vespa

    6,961View on GitHub↗

    Vespa is a distributed search engine, vector database, and machine learning ranking engine. It serves as an AI search platform designed to handle large-scale document indexing and complex query processing across a cluster of nodes, combining keyword retrieval with high-dimensional embedding storage for semantic similarity search. The platform distinguishes itself by integrating machine learning models directly into the search pipeline to perform real-time inference and ranking. It converts these models into ranking expressions to score and order results based on relevance, while providing a s

    Java
    View on GitHub↗6,961
  • Compare all 30 related projects→