SAP RFC/BAPI and transactional CDC

Use the @bijection/connectors/sap entrypoint to declare SAP RFC/BAPI and transactional CDC 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
RFC function	`rfc`	RFC/BAPI
SAP change stream	`cdc`	ABAP CDC

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

RFC function

rfc: RFC/BAPI

The following example matches configuration standard.

import { sap } from "@bijection/connectors/sap";
import { v } from "bijection/values";
import { makeFunctionReference } from "bijection/server";

export const writeDemo = sap.function.rfc({
  name: "BAPI_SALESORDER_CREATEFROMDAT2",
  digest: "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa",
  args: {
    import: v.object({ ORDER_HEADER_IN: v.object({ DOC_TYPE: v.string() }) }),
    changing: v.object({}),
    table: v.object({}),
  },
  output: v.object({
    export: v.object({ SALESDOCUMENT: v.string() }),
    changing: v.object({}),
    table: v.object({}),
  }),
  access: {
    read: makeFunctionReference<"query", any, [null]>("policies:sap"),
    reads: [],
  },
  governingRule: makeFunctionReference<"query", any, [null]>("policies:sap"),
});

Inferred record types

{
  "key": string;
  "contract_digest": string;
}

The function references identify application policy queries. Implement those policies in your application; the references alone grant no authority.

Configuration: standard

Case: sap/function/rfc/standard. Connection and resource configuration are declared by this exact case. Credential kind: http. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`endpoint`	string	Yes	Shared connection

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {
      "records": {
        "read": {
          "query": "policies:sap"
        },
        "reads": []
      }
    },
    "defaults": {},
    "connector": "http",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "http",
    "connection_fields": [
      "endpoint"
    ],
    "address": {
      "kind": "setup",
      "field": "endpoint"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "endpoint": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      }
    }
  },
  "execution": null
}

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

Contract	Meaning
Initial	Enumeration of observed records
Changes	Repeated observations of current records
Deletions	Deletion detection unsupported
Resume	No continuation
Gap	Not applicable
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {
      "records": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      }
    },
    "nativeInputLimitBytes": null,
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange records",
          "limitBytes": null
        }
      },
      {
        "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": "enumeration",
  "changes": "observations",
  "deletions": "unsupported",
  "resume": "none",
  "retentionMs": null,
  "gap": "not_applicable",
  "limits": {
    "http_response_bytes": "524288"
  },
  "restrictions": [],
  "commands": {
    "invoke": {
      "target": "records",
      "delivery": "single_attempt",
      "condition": "unconditional",
      "replayWindowMs": null,
      "maxDeliveryHours": "1",
      "providerEnforcedExpiry": false
    }
  }
}

Commands

Command	Target	Condition	Delivery
`invoke`	records	Unconditional	Single dispatch attempt

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": {
            "records": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            }
          },
          "nativeInputLimitBytes": null,
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange records",
                "limitBytes": null
              }
            },
            {
              "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": "enumeration",
        "changes": "observations",
        "deletions": "unsupported",
        "resume": "none",
        "retentionMs": null,
        "gap": "not_applicable",
        "limits": {
          "http_response_bytes": "524288"
        },
        "restrictions": [],
        "commands": {
          "invoke": {
            "target": "records",
            "delivery": "single_attempt",
            "condition": "unconditional",
            "replayWindowMs": null,
            "maxDeliveryHours": "1",
            "providerEnforcedExpiry": false
          }
        }
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {
    "invoke": {
      "target": "records",
      "condition": {
        "kind": "unconditional"
      },
      "delivery": {
        "kind": "single_attempt",
        "retention": {
          "kind": "unknown"
        },
        "max_delivery_hours": 1
      }
    }
  }
}

Recorded checks

Requirement	Scope	Evidence	Result
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	Java gateway checks exercise interface drift, RETURN rollback and lost replies. Live SAP and native deployment admission remain unqualified.	Execution result unavailable
command-response-lost	{“kind”:“command”,“name”:“invoke”}	Java gateway checks exercise interface drift, RETURN rollback and lost replies. Live SAP and native deployment admission remain unqualified.	Execution result unavailable
identity-account	{“kind”:“connection”}	Java gateway checks exercise interface drift, RETURN rollback and lost replies. Live SAP and native deployment admission remain unqualified.	Execution result unavailable

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

SAP change stream

cdc: ABAP CDC

The following example matches configuration standard.

import { sap } from "@bijection/connectors/sap";
import { v } from "bijection/values";
import { makeFunctionReference } from "bijection/server";

export const demoRows = sap.stream.cdc({
  name: "ORDERS",
  digest: "bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb",
  row: {
    MANDT: v.string(),
    VBELN: v.string(),
    NETWR: v.string(),
    WAERK: v.string(),
  },
  access: {
    read: makeFunctionReference<"query", any, [null]>("policies:sap"),
    reads: [],
  },
});

Inferred record types

{
  "key": string;
  "row": { VBELN: string; NETWR: string; WAERK: string; MANDT: string; };
}

The function references identify application policy queries. Implement those policies in your application; the references alone grant no authority.

Configuration: standard

Case: sap/stream/cdc/standard. Connection and resource configuration are declared by this exact case. Credential kind: http. Keep credential material in the private credential inventory.

Setting	Type	Required	Owner
`endpoint`	string	Yes	Shared connection
`epoch`	string	Yes	Shared connection

Complete configuration contract

{
  "setup": [],
  "resource": {
    "access": {
      "records": {
        "read": {
          "query": "policies:sap"
        },
        "reads": []
      }
    },
    "defaults": {},
    "connector": "http",
    "output": {
      "kind": "single",
      "collection": "records"
    },
    "credential_kind": "http",
    "connection_fields": [
      "endpoint",
      "epoch"
    ],
    "address": {
      "kind": "setup",
      "field": "endpoint"
    }
  },
  "connection_setup": {
    "type": "object",
    "value": {
      "endpoint": {
        "fieldType": {
          "type": "string"
        },
        "optional": false
      },
      "epoch": {
        "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	Complete change feed under the declared contract
Deletions	Explicit deletion evidence
Resume	Provider source position
Gap	Explicit repair required after a gap
Retention	Unspecified

Complete native profile

{
  "movement": {
    "exchanges": {
      "records": {
        "200": {
          "placement": "retained_bytes",
          "interpretation": "json",
          "projectsBeforeRetention": false,
          "retainedBodyLimitBytes": "524288",
          "fileLimitBytes": null
        }
      }
    },
    "nativeInputLimitBytes": null,
    "steps": [
      {
        "id": "acquire.1",
        "inputs": [],
        "action": {
          "operation": "acquire",
          "subject": "exchange records",
          "limitBytes": null
        }
      },
      {
        "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": "complete_feed",
  "deletions": "explicit_events",
  "resume": "source_position",
  "retentionMs": null,
  "gap": "explicit_repair",
  "limits": {
    "http_response_bytes": "524288"
  },
  "restrictions": [],
  "commands": {}
}

Commands, occurrences and artifacts

{
  "records": {
    "records": {
      "protocol": "change_feed",
      "coverage": "committed_prefix",
      "consistency": "observations",
      "atomicity": "record",
      "history": "complete_changes",
      "recordRefresh": false,
      "reconciliation": false,
      "notifications": false,
      "snapshotMaxRows": null,
      "profile": {
        "movement": {
          "exchanges": {
            "records": {
              "200": {
                "placement": "retained_bytes",
                "interpretation": "json",
                "projectsBeforeRetention": false,
                "retainedBodyLimitBytes": "524288",
                "fileLimitBytes": null
              }
            }
          },
          "nativeInputLimitBytes": null,
          "steps": [
            {
              "id": "acquire.1",
              "inputs": [],
              "action": {
                "operation": "acquire",
                "subject": "exchange records",
                "limitBytes": null
              }
            },
            {
              "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": "complete_feed",
        "deletions": "explicit_events",
        "resume": "source_position",
        "retentionMs": null,
        "gap": "explicit_repair",
        "limits": {
          "http_response_bytes": "524288"
        },
        "restrictions": [],
        "commands": {}
      }
    }
  },
  "occurrences": null,
  "artifacts": {
    "raw_archive": false,
    "native_file_transfer_limit_bytes": null,
    "external_versions": false,
    "files": {}
  },
  "commands": {}
}

Recorded checks

Requirement	Scope	Evidence	Result
change-history-gap	{“kind”:“collection”,“name”:“records”}	The ABAP add-on owns seeded history, update-LUW events and epoch refusal. ABAP activation and hosted CDC recovery require a real SAP system.	Execution result unavailable
page-publication-recovery	{“kind”:“collection”,“name”:“records”}	The ABAP add-on owns seeded history, update-LUW events and epoch refusal. ABAP activation and hosted CDC recovery require a real SAP system.	Execution result unavailable
identity-account	{“kind”:“connection”}	The ABAP add-on owns seeded history, update-LUW events and epoch refusal. ABAP activation and hosted CDC recovery require a real SAP system.	Execution result unavailable

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

Provider guidance

Use bijection source sap capture to capture selected JCo function interfaces and seeded ABAP CDC stream schemas. A sap.contract project generates typed bindings under _generated/sap. Private gateway endpoint, bearer credentials and CDC epoch belong to the normal HTTP connection binding. Function resources use exact captured signatures, explicit governing rules and single-attempt delivery. The customer gateway uses SAP JCo and keeps a BAPI and its explicit commit/rollback on one stateful session. RETURN selectors and BAPI mode are operator declarations. A lost reply remains unknown; no resend, durable SAP receipt or changed business state is inferred. CDC resources require the versioned Bijection ABAP add-on, complete committed seed and customer-installed business update hooks. The stream retains full after-images and deletions from sequence zero. Update-task failure rolls back its log records and sequence. Schema drift, a changed epoch or missing history refuses progress. The source does not claim atomic publication of an entire multi-row SAP transaction. The gateway and installable ABAP source live with Bijection’s SAP integration. SAP JCo binaries are supplied by the customer, and are not redistributed. These bindings neither install SAP objects nor establish live SAP qualification.

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

SAP RFC/BAPI and transactional CDC

Availability

Resources and modes

RFC function

rfc: RFC/BAPI

Configuration: standard

SAP change stream

cdc: ABAP CDC

Configuration: standard

Provider guidance

Provider references

Source and evidence

​Availability

​Resources and modes

​RFC function

​rfc: RFC/BAPI

​Configuration: standard

​SAP change stream

​cdc: ABAP CDC

​Configuration: standard

​Provider guidance

​Provider references

​Source and evidence

Availability

Resources and modes

RFC function

rfc: RFC/BAPI

Configuration: standard

SAP change stream

cdc: ABAP CDC

Configuration: standard

Provider guidance

Provider references

Source and evidence