From 0131401a19967fb157e540b23a9b1fa530f783e5 Mon Sep 17 00:00:00 2001
From: twthorn <thomaswilliamthornton@gmail.com>
Date: Wed, 3 Apr 2024 12:36:52 -0500
Subject: [PATCH] DBZ-7698 Add instance method for load

---
 .../debezium/pipeline/txmetadata/TransactionContext.java | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/debezium-core/src/main/java/io/debezium/pipeline/txmetadata/TransactionContext.java b/debezium-core/src/main/java/io/debezium/pipeline/txmetadata/TransactionContext.java
index 9ccf14ba7..c32f4941d 100644
--- a/debezium-core/src/main/java/io/debezium/pipeline/txmetadata/TransactionContext.java
+++ b/debezium-core/src/main/java/io/debezium/pipeline/txmetadata/TransactionContext.java
@@ -57,6 +57,15 @@ public Map<String, Object> store(Map<String, Object> offset) {
         return offset;
     }
 
+    /**
+     * Instance method to allow for overriding by custom transaction contexts.
+     * @param offsets Offsets to load
+     * @return TransactionContext instance with loaded offsets
+     */
+    public TransactionContext newTransactionContextFromOffsets(Map<String, ?> offsets) {
+        return TransactionContext.load(offsets);
+    }
+
     @SuppressWarnings("unchecked")
     public static TransactionContext load(Map<String, ?> offsets) {
         final Map<String, Object> o = (Map<String, Object>) offsets;