MakeMetrics makes the metrics for stream ingestion job monitoring.

CannotSetExpirationWindowErr get returned if the user attempts to specify the EXPIRATION WINDOW option to create a replication stream, as this job setting should only be set from the producer cluster.

MergedSubscription combines multiple subscriptions into a single merged stream of events.

Metrics are for production monitoring of stream ingestion jobs.

PartitionEvent augments a normal event with the partition it came from.