118 source and sink connectors for Surgewave Connect.
Surgewave.Connectors provides a comprehensive library of pre-built connectors that move data between Surgewave topics and external systems. Each connector is packaged as a .swpkg plugin and runs inside Surgewave Connect. Sources ingest data into Surgewave; sinks push data out. Connectors handle serialization, error recovery, offset tracking, and back-pressure automatically.
Cassandra, DynamoDB, Elasticsearch, Firestore, InfluxDB, MongoDB, MySql, Neo4j, Neptune, Oracle, PostgreSql, Redis, Snowflake, Spanner, SqlServer, TimescaleDB, TigerBeetle
AWS Bedrock, Comprehend, EFS, Kinesis, SNS, SQS, S3 | Azure Blob, CosmosDb, OpenAI, Queue, ServiceBus, Table, TextAnalytics | GCP BigQuery, Bigtable, Language, PubSub, Storage, VertexAI
Akka, AMQP, Beanstalkd, Kafka Bridge, Matter, MQTT, Nanomsg, NATS (+ KV, ObjectStore), NSQ, Pulsar, RabbitMQ, ZeroMQ
Anthropic, Azure OpenAI, GCP VertexAI, Grok, HuggingFace, Ollama, OpenAI, SpaCy
Alexa, Discord, Facebook, Facebook Messenger, Instagram, LinkedIn, Mattermost, Reddit, RocketChat, Slack, Telegram, Twitter
Google Drive, Google Home, Google Photos, Microsoft Teams, OneDrive, SignalR, WhatsApp
CSV, Excel, FileStream, ICal, Parquet, Sftp
GraphQL, Http, HttpServer, Imap, Smtp, SocketServer, SocketStream, Stdio, Tcp, Udp
Flink, InProc, Orleans, SAP EventMesh, SAP HANA, SAP OData, Spark
Git, Hue, Surgewave Bridge, Weather
Batching, DeepL, Generator, Logic, Mirror, Script, Sequence, TextChunking, VectorStore, Wikipedia, Xmpp
# Install a specific connector
surgewave plugin install surgewave-connector-postgresql-x.y.z.swpkg
# Install all connectors
surgewave plugin install surgewave-connectors-all-x.y.z.swpkg{
"name": "pg-source",
"connector.class": "PostgreSqlSourceConnector",
"connection.string": "Host=localhost;Database=mydb;Username=surgewave",
"topics": "pg-changes",
"poll.interval.ms": 1000
}dotnet build Kuestenlogik.Surgewave.Connectors.slnx -c Release.\scripts\collect-plugins.ps1 -BuildApache 2.0