diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/converters/PostgresCloudEventsMaker.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/converters/PostgresCloudEventsMaker.java
index e0f3bf989..1c7479080 100644
--- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/converters/PostgresCloudEventsMaker.java
+++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/converters/PostgresCloudEventsMaker.java
@@ -25,6 +25,7 @@ public PostgresCloudEventsMaker(RecordParser parser, SerializerType contentType,
     public String ceId() {
         return "name:" + recordParser.getMetadata(AbstractSourceInfo.SERVER_NAME_KEY)
                 + ";lsn:" + recordParser.getMetadata(PostgresRecordParser.LSN_KEY).toString()
-                + ";txId:" + recordParser.getMetadata(PostgresRecordParser.TXID_KEY).toString();
+                + ";txId:" + recordParser.getMetadata(PostgresRecordParser.TXID_KEY).toString()
+                + ";sequence:" + recordParser.getMetadata(PostgresRecordParser.SEQUENCE_KEY).toString();
     }
 }
diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/converters/PostgresRecordParser.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/converters/PostgresRecordParser.java
index 7d58cfd42..32815ea07 100644
--- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/converters/PostgresRecordParser.java
+++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/converters/PostgresRecordParser.java
@@ -25,11 +25,13 @@ public class PostgresRecordParser extends RecordParser {
     static final String TXID_KEY = "txId";
     static final String XMIN_KEY = "xmin";
     static final String LSN_KEY = "lsn";
+    static final String SEQUENCE_KEY = "sequence";
 
     static final Set<String> POSTGRES_SOURCE_FIELD = Collect.unmodifiableSet(
             TXID_KEY,
             XMIN_KEY,
-            LSN_KEY);
+            LSN_KEY,
+            SEQUENCE_KEY);
 
     public PostgresRecordParser(Schema schema, Struct record) {
         super(schema, record, Envelope.FieldName.BEFORE, Envelope.FieldName.AFTER);