diff --git a/package-lock.json b/package-lock.json
index da5b49c..9390581 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -1,12 +1,12 @@
 {
   "name": "aws-lambda-stream",
-  "version": "1.0.30",
+  "version": "1.0.31",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "aws-lambda-stream",
-      "version": "1.0.28",
+      "version": "1.0.31",
       "license": "MIT",
       "dependencies": {
         "object-sizeof": "^2.6.0"
diff --git a/package.json b/package.json
index 58187c6..ab14417 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "aws-lambda-stream",
-  "version": "1.0.30",
+  "version": "1.0.31",
   "description": "Create stream processors with AWS Lambda functions.",
   "keywords": [
     "aws",
diff --git a/src/sinks/eventbridge.js b/src/sinks/eventbridge.js
index 9ab9390..4c7adf1 100644
--- a/src/sinks/eventbridge.js
+++ b/src/sinks/eventbridge.js
@@ -21,6 +21,7 @@ export const publishToEventBridge = ({ // eslint-disable-line import/prefer-defa
   maxPublishRequestSize = Number(process.env.PUBLISH_MAX_REQ_SIZE) || Number(process.env.MAX_REQ_SIZE) || 256 * 1024,
   batchSize = Number(process.env.PUBLISH_BATCH_SIZE) || Number(process.env.BATCH_SIZE) || 10,
   parallel = Number(process.env.PUBLISH_PARALLEL) || Number(process.env.PARALLEL) || 8,
+  endpointId = process.env.BUS_ENDPOINT_ID,
   handleErrors = true,
   retryConfig,
   step = 'publish',
@@ -47,6 +48,7 @@ export const publishToEventBridge = ({ // eslint-disable-line import/prefer-defa
       Entries: batchUow.batch
         .filter((uow) => uow[publishRequestEntryField])
         .map((uow) => uow[publishRequestEntryField]),
+      EndpointId: endpointId || undefined,
     },
   });