Docs
  • Release notes
  • Troubleshoot
  • Reference
  • Elastic fundamentals
  • Solutions and use cases
  • Manage data
  • Explore and analyze
  • Deploy and manage
  • Manage your Cloud account and preferences
  • Troubleshoot
  • Release notes
  • Reference
  • Extend and contribute
  • Contribute to the docs
  • The Elasticsearch data store
    • Index basics
    • Near real-time search
    • Data streams
    • Mapping
    • Text analysis
    • Templates
    • Aliases
    • Manage data from the command line
  • Ingest: Bring your data to Elastic
    • Ingesting time series data
    • Ingesting data for Elastic solutions
    • Ingesting data from applications
    • Ingest architectures
    • Sample data
    • Upload data files
    • Transform and enrich data
    • Ingest tools overview
  • Data lifecycle
    • Data tiers
    • Index lifecycle management
    • Data stream lifecycle
    • Curator
    • Rollup
  • Migrate your Elasticsearch data
    • Reindex from a self-managed cluster
    • Migrate system indices
    • Migrate with minimal downtime
  • Use case: use Elasticsearch to manage time series data
  • View as Markdown
  • Report a docs issue
  • Edit this page
  • Learn how to contribute
On this page
  • Elastic Agent with Kafka as middleware message queue architectures
Loading
  1. Elastic Docs /
  2. Manage data /
  3. Ingest: Bring your data to Elastic /
  4. Ingest architectures

Elastic Agent to Elasticsearch with Kafka as middleware message queue

Image showing Elastic Agent collecting data and using Kafka as a message queue enroute to Elasticsearch
× Image showing Elastic Agent collecting data and using Kafka as a message queue enroute to Elasticsearch
Ingest models

Elastic Agent to Logstash to Kafka to Logstash to Elasticsearch: Kafka as middleware message queue.
Logstash reads data from Kafka and routes it to Elasticsearch clusters (and/or other destinations).

Elastic Agent to Logstash to Kafka to Kafka ES Sink to Elasticsearch: Kafka as middleware message queue.
Kafka ES sink connector reads from Kafka and writes to Elasticsearch.

Use when
You are standardizing on Kafka as middleware message queue between Elastic Agent and Elasticsearch
Notes
The transformation from raw data to Elastic Common Schema (ECS) and any other enrichment can be handled by Logstash as described in Elastic Agent to Logstash (for enrichment) to Elasticsearch.

Elastic Agent with Kafka as middleware message queue architectures

  • Elastic Agent to Logstash to Kafka to Logstash to Elasticsearch: Kafka as middleware message queue
  • Elastic Agent to Logstash to Kafka to Kafka ES Sink to Elasticsearch: Kafka as middleware message queue
Previous
Elastic Agent to proxy to Elasticsearch
Next
Elastic Agent to Logstash to Kafka to Logstash to Elasticsearch: Kafka as middleware message queue
Elastic logo
  • Trademarks
  • Terms of Use
  • Privacy
  • Sitemap

© 2025 Elasticsearch B.V. All Rights Reserved.

This content is available in different formats for convenience only. All original licensing terms apply.

Elasticsearch is a trademark of Elasticsearch B.V., registered in the U.S. and in other countries. Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant logo are trademarks of the Apache Software Foundation in the United States and/or other countries.