I think we don't use replication, but rather we have a kafka connector