mqtt

Use the @bijection/connectors/mqtt entrypoint to declare mqtt resources.

Availability

This page describes the pinned source package. Published availability is unestablished for this artifact. Source build and package availability.

Resources and modes

Resource	Mode	Description
topic	`messages`	messages
telemetry	`latest`	latest

Declare a resource in application code, then bind deployment-specific settings and credentials. See typed resources, connections and source inspection.

topic

messages: messages

The following example matches configuration standard.

import { mqtt } from "@bijection/connectors/mqtt";
import { v } from "bijection/values";
const schema = { id: v.string() };
export const source = mqtt.topic.messages({ schema, identity: ["id"] });

Inferred record types

{
  "messageId": string;
  "data": { id: string; };
}

Configuration: standard

Case: mqtt/topic/messages/standard. Connection and resource configuration are declared by this exact case. Credential kind: mqtt. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`topic`	string	Yes	Resource binding
`endpoint`	string	Yes	Shared connection
`clientId`	string	Yes	Resource binding
`identityEndpoint`	string	Yes	Shared connection

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {},
    "defaults": {},
    "connector": "mqtt",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "mqtt",
    "connection_fields": [
      "endpoint",
      "identityEndpoint"
    ]
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "topic": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "endpoint": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "clientId": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "identityEndpoint": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: records

Contract	Meaning
Initial	No initial acquisition
Changes	Delivered message occurrences
Deletions	Deletion detection unsupported
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {},
    "nativeInputLimitBytes": "0",
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "native input",
          "limitBytes": "0"
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "records"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "source rows",
          "reason": "serving",
          "release": "replacement"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "source rows",
          "visibility": "with_acquisition"
        }
      }
    ]
  },
  "initial": "none",
  "changes": "delivered_messages",
  "deletions": "unsupported",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "exchange_evidence_bytes": "524288",
    "publication_page_records": "128",
    "record_fields": "32"
  },
  "restrictions": [
    "Message custody is distinct from current entity state and provider deletion"
  ],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "records": {
      "protocol": "record_observation",
      "coverage": "records",
      "consistency": "observations",
      "atomicity": "record",
      "history": "observations",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {},
          "nativeInputLimitBytes": "0",
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "native input",
                "limitBytes": "0"
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "records"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "source rows",
                "reason": "serving",
                "release": "replacement"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "source rows",
                "visibility": "with_acquisition"
              }
            }
          ]
        },
        "initial": "none",
        "changes": "delivered_messages",
        "deletions": "unsupported",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "exchange_evidence_bytes": "524288",
          "publication_page_records": "128",
          "record_fields": "32"
        },
        "restrictions": [
          "Message custody is distinct from current entity state and provider deletion"
        ],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	This resource is inventoried from its executable declaration. No case-scoped check receipt is attached; historical provider observations do not qualify this configuration.	Execution result unavailable

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

telemetry

latest: latest

The following example matches configuration standard.

import { mqtt } from "@bijection/connectors/mqtt";
import { v } from "bijection/values";

export const readings = mqtt.telemetry.latest({
  record: {
    schema: {
      eventId: v.string(),
      id: v.string(),
      at: v.int64(),
      value: v.number(),
    },
    encoding: "json",
    time: { field: "at", unit: "microseconds" },
  },
  archive: true,
  history: true,
  series: { table: "observations", key: "id", orderBy: "at" },
  latest: { key: ["id"], publishEvery: { seconds: 1 } },
  identity: ["eventId"],
});

Inferred record types

{
  "eventId": string;
  "id": string;
  "at": bigint;
  "value": number;
}

Configuration: standard

Case: mqtt/telemetry/latest/standard. Connection and resource configuration are declared by this exact case. Credential kind: mqtt. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`topic`	string	Yes	Resource binding
`endpoint`	string	Yes	Shared connection
`clientId`	string	Yes	Resource binding
`identityEndpoint`	string	Yes	Shared connection

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {},
    "defaults": {},
    "connector": "mqtt",
    "output": {
      "kind": "single",
      "collection": "latest"
    },
    "credential_kind": "mqtt",
    "connection_fields": [
      "endpoint",
      "identityEndpoint"
    ]
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "topic": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "endpoint": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "clientId": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "identityEndpoint": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

Native admission analysis is available for this exact declaration. Collection: latest

Contract	Meaning
Initial	No initial acquisition
Changes	Latest observed state per key
Deletions	Deletion detection unsupported
Resume	Opaque cursor
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {},
    "nativeInputLimitBytes": "0",
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "native input",
          "limitBytes": "0"
        }
      },
      {
        "id": "retain.1",
        "inputs": [
          "acquire.1"
        ],
        "action": {
          "operation": "retain",
          "subject": "acquisition evidence",
          "reason": "recovery",
          "release": "acquisition_custody"
        }
      },
      {
        "id": "interpret.1",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "interpret",
          "subject": "acquired input",
          "produces": "occurrences"
        }
      },
      {
        "id": "materialize.1",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "latest projection",
          "reason": "latest",
          "release": "replacement"
        }
      },
      {
        "id": "materialize.2",
        "inputs": [
          "retain.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "raw archive",
          "reason": "archive",
          "release": "output_retention"
        }
      },
      {
        "id": "materialize.3",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "history",
          "reason": "history",
          "release": "output_retention"
        }
      },
      {
        "id": "materialize.4",
        "inputs": [
          "interpret.1"
        ],
        "action": {
          "operation": "materialize",
          "subject": "series observations",
          "reason": "series",
          "release": "output_retention"
        }
      },
      {
        "id": "publish.1",
        "inputs": [
          "materialize.1"
        ],
        "action": {
          "operation": "publish",
          "subject": "latest projection",
          "visibility": "timed"
        }
      }
    ]
  },
  "initial": "none",
  "changes": "latest_per_key",
  "deletions": "unsupported",
  "resume": "opaque_cursor",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "exchange_evidence_bytes": "524288",
    "publication_page_records": "8",
    "record_fields": "32"
  },
  "restrictions": [
    "JSON telemetry retains source-qualified opaque occurrence identities; capacity exhaustion stops acceptance before acknowledgement",
    "Message custody is distinct from current entity state and provider deletion"
  ],
  "commands": {}
}

This case declares occurrence processing. Its complete contract below describes the admitted interpretation. This case declares a raw archive output.

Commands, occurrences and artifacts

{
  "records": {
    "latest": {
      "protocol": "stream_latest",
      "coverage": "latest_per_key",
      "consistency": "observations",
      "atomicity": "record",
      "history": "latest_state",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {},
          "nativeInputLimitBytes": "0",
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "native input",
                "limitBytes": "0"
              }
            },
            {
              "id": "retain.1",
              "inputs": [
                "acquire.1"
              ],
              "action": {
                "operation": "retain",
                "subject": "acquisition evidence",
                "reason": "recovery",
                "release": "acquisition_custody"
              }
            },
            {
              "id": "interpret.1",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "interpret",
                "subject": "acquired input",
                "produces": "occurrences"
              }
            },
            {
              "id": "materialize.1",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "latest projection",
                "reason": "latest",
                "release": "replacement"
              }
            },
            {
              "id": "materialize.2",
              "inputs": [
                "retain.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "raw archive",
                "reason": "archive",
                "release": "output_retention"
              }
            },
            {
              "id": "materialize.3",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "history",
                "reason": "history",
                "release": "output_retention"
              }
            },
            {
              "id": "materialize.4",
              "inputs": [
                "interpret.1"
              ],
              "action": {
                "operation": "materialize",
                "subject": "series observations",
                "reason": "series",
                "release": "output_retention"
              }
            },
            {
              "id": "publish.1",
              "inputs": [
                "materialize.1"
              ],
              "action": {
                "operation": "publish",
                "subject": "latest projection",
                "visibility": "timed"
              }
            }
          ]
        },
        "initial": "none",
        "changes": "latest_per_key",
        "deletions": "unsupported",
        "resume": "opaque_cursor",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "exchange_evidence_bytes": "524288",
          "publication_page_records": "8",
          "record_fields": "32"
        },
        "restrictions": [
          "JSON telemetry retains source-qualified opaque occurrence identities; capacity exhaustion stops acceptance before acknowledgement",
          "Message custody is distinct from current entity state and provider deletion"
        ],
        "commands": {}
      }
    }
  },
  "occurrences": {
    "record": {
      "schema": {
        "type": "object",
        "value": {
          "at": {
            "fieldType": {
              "type": "bigint"
            },
            "optional": false
          },
          "eventId": {
            "fieldType": {
              "type": "string"
            },
            "optional": false
          },
          "id": {
            "fieldType": {
              "type": "string"
            },
            "optional": false
          },
          "value": {
            "fieldType": {
              "type": "number"
            },
            "optional": false
          }
        }
      },
      "encoding": {
        "kind": "json"
      },
      "time": {
        "field": "at",
        "unit": "microseconds"
      }
    }
  },
  "artifacts": {
    "raw_archive": true,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
change-history-gap	{“kind”:“collection”,“name”:“latest”}	This resource is inventoried from its executable declaration. No case-scoped check receipt is attached; historical provider observations do not qualify this configuration.	Execution result unavailable
page-publication-recovery	{“kind”:“collection”,“name”:“latest”}	This resource is inventoried from its executable declaration. No case-scoped check receipt is attached; historical provider observations do not qualify this configuration.	Execution result unavailable

Hosted qualification: unestablished for this catalog configuration. Installed connections report their own identity, authority and current status.

Provider guidance

These recipes return ordinary typed resources or atomic resource groups. The registration in native.ts owns their callable factories, named modes and representative cases. Credentials, endpoints and physical resource selection belong to deployment bindings. Application schemas and message interpretation belong to the declaration. Acquisition and recovery guarantees come from native admission, not the mode name. Each public resource has a case and explicit scoped evidence requirements. These registrations alone establish no executed provider checks or hosted qualification. The catalog reports missing execution evidence as unestablished. Native source inspection remains authoritative for the actual installation. Protocol helpers such as HTTP request builders and generated operation descriptors are authoring primitives. They do not count as independently installable provider resources. External compute remains owned by its provider.

Provider references

Provider references and prerequisites are maintained in the connector guidance above. No separate provider-documentation review date is recorded.

Source and evidence

Canonical connector source, native analysis and check receipts. Connector artifact: 905888ea276a2a28e36981a79e8142b2547ea451c3e63162cb6915ad4a7d1305. The resource declaration examples above are compiled and compared with exact catalog declarations. Recorded checks apply only to their source, declaration and runtime identities. Configure a connection and inspect its status to establish deployment-specific readiness.

Get Started

Use-case atlas

Platform

Data and Operations

Guides

Client Libraries

Tools

API Reference

Availability

Resources and modes

topic

messages: messages

Configuration: standard

telemetry

latest: latest

Configuration: standard

Provider guidance

Provider references

Source and evidence

​Availability

​Resources and modes

​topic

​messages: messages

​Configuration: standard

​telemetry

​latest: latest

​Configuration: standard

​Provider guidance

​Provider references

​Source and evidence

Availability

Resources and modes

topic

messages: messages

Configuration: standard

telemetry

latest: latest

Configuration: standard

Provider guidance

Provider references

Source and evidence