NewOffsetStore creates an instance of OffsetStore.

NewSchemaUtils creates an instance of SchemaUtils.

Config defines the postgres offset store configuration.

OffsetStore implements the OffsetStore interface and helps persist events in a Postgres database.

SchemaUtils help create the various test tables in unit/integration tests.