diff --git a/src/Consumer.php b/src/Consumer.php index 215f5dc..a4791f3 100644 --- a/src/Consumer.php +++ b/src/Consumer.php @@ -178,12 +178,12 @@ protected function makeReplication(): MySQLReplicationFactory { $connection = $this->connection; // Get databases of replication - $databasesOnly = array_replace( + $databasesOnly = array_merge( $this->config->get('databases_only', []), $this->triggerManager->getDatabases($connection) ); // Get tables of replication - $tablesOnly = array_replace( + $tablesOnly = array_merge( $this->config->get('tables_only', []), $this->triggerManager->getTables($connection) );