Streams, queues & webhooks

Events in motion between systems.

All connections Search the catalog

19 listings.

Connector · Managed early access

Webhook Ingest

Signed HTTP event deliveries with source and tenant context.

View listing

Connector · Reference · built on request

Airbyte

Connections, sync jobs, and job status from Airbyte Cloud or Self-Managed, with syncs started and cancelled through the Airbyte API.

View listing

Connector · Reference · built on request

Amazon EventBridge

Events from AWS services, your own code, and SaaS vendors, routed by EventBridge rules to an API destination and replayed from archives.

View listing

Connector · Reference · built on request

Amazon Kinesis Data Streams

Records from Kinesis data stream shards through GetRecords or SubscribeToShard, plus stream and consumer state.

View listing

Connector · Reference · built on request

Amazon SNS

Topic notifications, subscription confirmations, and filter policies from Amazon SNS over HTTPS subscriptions and the SNS API.

View listing

Connector · Reference · built on request

Amazon SQS

Messages and queue attributes from Amazon SQS standard and FIFO queues, with dead-letter queue redrive, through the SQS API.

View listing

Connector · Reference · built on request

Apache Kafka

Events from Kafka topics through the Consumer, Producer, and Admin APIs over Kafka's binary protocol on TCP.

View listing

Connector · Reference · built on request

Azure Event Hubs

Partitioned event streams from Azure Event Hubs, read over AMQP 1.0 or Kafka in a consumer group and sent by HTTPS POST.

View listing

Connector · Reference · built on request

Azure Service Bus

Queue and topic-subscription messages from Azure Service Bus by Peek-Lock over REST or AMQP 1.0, with dead-letter and scheduled delivery.

View listing

Connector · Reference · built on request

Confluent Cloud

Records, topics, consumer lag, clusters, and managed connectors from Confluent Cloud through its Kafka REST and management APIs.

View listing

Connector · Reference · built on request

Fivetran

Connection status, sync history, and sync_start and sync_end webhook events from Fivetran, with syncs and pauses through its REST API.

View listing

Connector · Reference · built on request

Google Cloud Pub/Sub

Messages from Pub/Sub topics by pull, push to an HTTPS endpoint, or export to BigQuery and Cloud Storage, through pubsub.googleapis.com.

View listing

Connector · Reference · built on request

Hookdeck

Inbound requests, events, delivery attempts, and issues from Hookdeck, with retries and connection pauses through its REST API.

View listing

Connector · Reference · built on request

NATS

Messages on NATS subjects and JetStream streams, with Key Value and Object store reads, through NATS client protocols.

View listing

Connector · Reference · built on request

RabbitMQ

Messages, queue depths, message rates, and broker health from RabbitMQ over AMQP and the management HTTP API.

View listing

Connector · Reference · built on request

Redpanda

Events from Redpanda topics through the Kafka API, the HTTP Proxy, the Admin API, and the Schema Registry API.

View listing

Connector · Reference · built on request

RudderStack

Identify, Track, Page, Screen, Group, and Alias events from RudderStack sources via a Webhook destination, written back over the HTTP API.

View listing

Connector · Reference · built on request

Svix

Applications, endpoints, messages, and delivery attempts from Svix, with resends and recoveries through its REST API.

View listing

Connector · Reference · built on request

Twilio Segment

Identify, Track, Page, Screen, Group, and Alias calls from Segment via the Webhooks destination, written back by the Tracking API.

View listing

Operators that use these

Operators read from connections and signals like these and propose changes for your approval.

Live in BearScope

Operations Analyst

Analyze customer conversations, call records, and operational metrics in BearScope.

Managed early access

Exception Routing

Review line exceptions and propose reroutes, reschedules, or dispatches.

Reference · built on request

Data Freshness

Checks each reporting source against its expected load cadence and proposes holding dependent reports when an input is stale.

Reference · built on request

Integration Health

Watches sync jobs and API errors on both sides of an integration and proposes a rerun, a credential check, or a pause.

Reference · built on request

Webhook Replay

Matches failed Stripe, Shopify, and GitHub webhook deliveries against receiver receipts and proposes a replay batch with no duplicates.

Reference · built on request

Quota Headroom

Reads cloud service quotas against usage and its trend. Proposes an increase request before a limit is reached.

Live in BearScope

Order Risk

Review order risk using connected commerce and customer-support records in BearScope.

Reference · built on request

Vendor Outage

Reads third-party status pages and your own integration error rates. Proposes a customer notice or a failover when a provider degrades.

About streams, queues & webhooks listings

Every listing here documents one system: what Fibric reads from it, what it can propose, what it needs, and where it stops. Reference listings describe the vendor's published interfaces; Fibric builds them under a managed deployment when you request them. Selecting a listing installs nothing.