@Override
    protected void createStagingTable() {
    }
Constructs the SqlManager.

@param opts the ReplicaDB ToolOptions describing the user's requested action.
src/main/java/org/replicadb/manager/KafkaManager.java