When using the source signal channel, the CommonConnectorConfig.isSignalDataCollection() method compares the data collection that a change is from with the string literal passed as the signal.data.collection.

This means signalingDataCollection.equals(dataCollectionId.identifier()) will always return false if any character escaping is used for the signal table config value, even if it can correctly be parsed into database.schema.table using the TableIdParser.

My suggested fix here is to use a parsed signal table TableId object to compare with the dataCollectionId.identifier() value instead of the config string value.