# Inputs Components

> 52 inputs components available. Fetch individual files for full configuration docs.

| Component | Description | Full Docs |
|-----------|-------------|----------|
| audit | Generates synthetic records stamped with a verifiable identity, for a matching `audit` output to check. | [audit.txt](/llms/components/inputs/audit.txt) |
| aws_cloudwatch_logs | Consumes log events from AWS CloudWatch Logs. | [aws_cloudwatch_logs.txt](/llms/components/inputs/aws_cloudwatch_logs.txt) |
| aws_dynamodb_cdc | Reads change data capture (CDC) events from DynamoDB Streams. | [aws_dynamodb_cdc.txt](/llms/components/inputs/aws_dynamodb_cdc.txt) |
| aws_kinesis | Receive messages from one or more Kinesis streams. | [aws_kinesis.txt](/llms/components/inputs/aws_kinesis.txt) |
| aws_s3 | Downloads objects within an Amazon S3 bucket, optionally filtered by a prefix, either by walking the items in the bucket | [aws_s3.txt](/llms/components/inputs/aws_s3.txt) |
| aws_sqs | Consume messages from an AWS SQS URL. | [aws_sqs.txt](/llms/components/inputs/aws_sqs.txt) |
| azure_blob_storage | Downloads objects within an Azure Blob Storage container, optionally filtered by a prefix. | [azure_blob_storage.txt](/llms/components/inputs/azure_blob_storage.txt) |
| azure_cosmosdb | Executes a SQL query against [Azure CosmosDB](https://learn.microsoft.com/en-us/azure/cosmos-db/introduction) and create | [azure_cosmosdb.txt](/llms/components/inputs/azure_cosmosdb.txt) |
| azure_queue_storage | Dequeue objects from an Azure Storage Queue. | [azure_queue_storage.txt](/llms/components/inputs/azure_queue_storage.txt) |
| azure_table_storage | Queries an Azure Storage Account Table, optionally with multiple filters. | [azure_table_storage.txt](/llms/components/inputs/azure_table_storage.txt) |
| batched | Consumes data from a child input and applies a batching policy to the stream. | [batched.txt](/llms/components/inputs/batched.txt) |
| broker | Allows you to combine multiple inputs into a single stream of data, where each input will be read in parallel. | [broker.txt](/llms/components/inputs/broker.txt) |
| csv | Reads one or more CSV files as structured records following the format described in RFC 4180. | [csv.txt](/llms/components/inputs/csv.txt) |
| dynamic | A special broker type where the inputs are identified by unique labels and can be created, changed and removed during ru | [dynamic.txt](/llms/components/inputs/dynamic.txt) |
| file | Consumes data from files on disk, emitting messages according to a chosen codec. | [file.txt](/llms/components/inputs/file.txt) |
| gcp_bigquery_select | Executes a `SELECT` query against BigQuery and creates a message for each row received. | [gcp_bigquery_select.txt](/llms/components/inputs/gcp_bigquery_select.txt) |
| gcp_cloud_storage | Downloads objects within a Google Cloud Storage bucket, optionally filtered by a prefix. | [gcp_cloud_storage.txt](/llms/components/inputs/gcp_cloud_storage.txt) |
| gcp_pubsub | Consumes messages from a GCP Cloud Pub/Sub subscription. | [gcp_pubsub.txt](/llms/components/inputs/gcp_pubsub.txt) |
| generate | Generates messages at a given interval using a [Bloblang](/guides/bloblang) mapping executed without a context. This all | [generate.txt](/llms/components/inputs/generate.txt) |
| http_client | Connects to a server and continuously performs requests for a single message. | [http_client.txt](/llms/components/inputs/http_client.txt) |
| http_server | Receive messages POSTed over HTTP(S). HTTP 2.0 is supported when using TLS, which is enabled when key and cert files are | [http_server.txt](/llms/components/inputs/http_server.txt) |
| inproc |  | [inproc.txt](/llms/components/inputs/inproc.txt) |
| kafka | Connects to Kafka brokers and consumes one or more topics. | [kafka.txt](/llms/components/inputs/kafka.txt) |
| kafka_franz | A Kafka input using the [Franz Kafka client library](https://github.com/twmb/franz-go). | [kafka_franz.txt](/llms/components/inputs/kafka_franz.txt) |
| mongodb | Executes a query and creates a message for each document received. | [mongodb.txt](/llms/components/inputs/mongodb.txt) |
| mqtt | Subscribe to topics on MQTT brokers. | [mqtt.txt](/llms/components/inputs/mqtt.txt) |
| mysql_cdc | Enables MySQL streaming for Expanso Edge. | [mysql_cdc.txt](/llms/components/inputs/mysql_cdc.txt) |
| nats | Subscribe to a NATS subject. | [nats.txt](/llms/components/inputs/nats.txt) |
| nats_jetstream | Reads messages from NATS JetStream subjects. | [nats_jetstream.txt](/llms/components/inputs/nats_jetstream.txt) |
| nats_kv | Watches for updates in a NATS key-value bucket. | [nats_kv.txt](/llms/components/inputs/nats_kv.txt) |
| nats_stream | Subscribe to a NATS Stream subject. Joining a queue is optional and allows multiple clients of a subject to consume usin | [nats_stream.txt](/llms/components/inputs/nats_stream.txt) |
| opcua | OPC UA input plugin | [opcua.txt](/llms/components/inputs/opcua.txt) |
| parquet | Reads and decodes [Parquet files](https://parquet.apache.org/docs/) into a stream of structured messages. | [parquet.txt](/llms/components/inputs/parquet.txt) |
| pg_stream | Streams changes from a PostgreSQL database using logical replication. | [pg_stream.txt](/llms/components/inputs/pg_stream.txt) |
| postgres_cdc | Streams changes from a PostgreSQL database using logical replication. | [postgres_cdc.txt](/llms/components/inputs/postgres_cdc.txt) |
| read_until | Reads messages from a child input until a consumed message passes a [Bloblang query](/guides/bloblang), at which point t | [read_until.txt](/llms/components/inputs/read_until.txt) |
| redis_list | Pops messages from the beginning of a Redis list using the BLPop command. | [redis_list.txt](/llms/components/inputs/redis_list.txt) |
| redis_pubsub | Consume from a Redis publish/subscribe channel using either the SUBSCRIBE or PSUBSCRIBE commands. | [redis_pubsub.txt](/llms/components/inputs/redis_pubsub.txt) |
| redis_scan | Scans the set of keys in the current selected database and gets their values, using the Scan and Get commands. | [redis_scan.txt](/llms/components/inputs/redis_scan.txt) |
| redis_streams | Pulls messages from Redis (v5.0+) streams with the XREADGROUP command. The `client_id` should be unique for each consume | [redis_streams.txt](/llms/components/inputs/redis_streams.txt) |
| redpanda | A Kafka input using the [Franz Kafka client library](https://github.com/twmb/franz-go). | [redpanda.txt](/llms/components/inputs/redpanda.txt) |
| resource | Resource is an input type that channels messages from a resource input, identified by its name. | [resource.txt](/llms/components/inputs/resource.txt) |
| schema_registry | Reads schemas from SchemaRegistry. | [schema_registry.txt](/llms/components/inputs/schema_registry.txt) |
| sequence | Reads messages from a sequence of child inputs, starting with the first and once that input gracefully terminates starts | [sequence.txt](/llms/components/inputs/sequence.txt) |
| socket | Connects to a tcp or unix socket and consumes a continuous stream of messages. | [socket.txt](/llms/components/inputs/socket.txt) |
| socket_server | Creates a server that receives a stream of messages over a TCP, UDP or Unix socket. | [socket_server.txt](/llms/components/inputs/socket_server.txt) |
| sql_raw | Executes a select query and creates a message for each row received. | [sql_raw.txt](/llms/components/inputs/sql_raw.txt) |
| sql_select | Executes a select query and creates a message for each row received. | [sql_select.txt](/llms/components/inputs/sql_select.txt) |
| stdin | Consumes data piped to stdin, chopping it into individual messages according to the specified scanner. | [stdin.txt](/llms/components/inputs/stdin.txt) |
| subprocess | Executes a command, runs it as a subprocess, and consumes messages from it over stdout. | [subprocess.txt](/llms/components/inputs/subprocess.txt) |
| tail | Tails local files with rotation handling and persistent checkpointing. | [tail.txt](/llms/components/inputs/tail.txt) |
| websocket | Connects to a websocket server and continuously receives messages. | [websocket.txt](/llms/components/inputs/websocket.txt) |

## Full Reference

See https://docs.expanso.io/components/inputs for complete documentation.