-record(database_sink, {
    name :: binary(),
    table :: binary(),
    upsert_key :: binary()
}).