feat: Allow indirect replication (#1070)

akka-projection-grpc-tests/src/it/resources/db/default-init.sql

@@ -136,4 +136,18 @@ CREATE TABLE IF NOT EXISTS akka_projection_timestamp_offset_store_DCC (
     -- the consumer lag is timestamp_consumed - timestamp_offset
     timestamp_consumed timestamp with time zone NOT NULL,
     PRIMARY KEY(slice, projection_name, timestamp_offset, persistence_id, seq_nr)
-);
+);
+
+CREATE TABLE IF NOT EXISTS akka_projection_timestamp_offset_store_DCD (
+    projection_name VARCHAR(255) NOT NULL,
+    projection_key VARCHAR(255) NOT NULL,
+    slice INT NOT NULL,
+    persistence_id VARCHAR(255) NOT NULL,
+    seq_nr BIGINT NOT NULL,
+    -- timestamp_offset is the db_timestamp of the original event
+    timestamp_offset timestamp with time zone NOT NULL,
+    -- timestamp_consumed is when the offset was stored
+    -- the consumer lag is timestamp_consumed - timestamp_offset
+    timestamp_consumed timestamp with time zone NOT NULL,
+    PRIMARY KEY(slice, projection_name, timestamp_offset, persistence_id, seq_nr)
+);