- Scanners - Decompress - JSON Documents - Lines - Tar - All - Sinks - AMQP 0.9 - AMQP 1.0 - AWS DynamoDB - AWS Kinesis - AWS Kinesis Firehose - AWS S3 - AWS SNS - AWS SQS - Azure Blob Storage - Azure CosmosDB - Azure Data Lake Gen2 - Azure Queue Storage - Azure Table Storage - Cassandra - Couchbase - Cypher - Discord - Elasticsearch - GCP BigQuery - GCP BigTable - GCP Cloud Storage - GCP PubSub - HDFS - HTTP - Kafka - MongoDB - NATS - NATS JetStream - NATS KV - NSQ - Opensearch - Pulsar - Pusher - Redis Hash - Redis List - Redis PubSub - Redis Streams - SFTP - Timeplus - Sources - AMQP 0.9 - AMQP 1.0 - AWS Kinesis - AWS S3 - AWS SQS - Azure Blob Storage - Azure CosmosDB - Azure Queue Storage - Azure Table Storage - Cassandra - GCP BigQuery Select - GCP Cloud Storage - GCP PubSub - Generate - HDFS - HTTP - Kafka - MongoDB Query - MongoDB Change Stream - MQTT - NATS - NATS JetStream - NATS KV - NSQ - Pulsar - Redis List - Redis PubSub - Redis Scan - Redis Streams - Socket - Timeplus