I am trying to build CDC pipeline to migrate MySQL database to MySQL database in different server.
Here’s the data collector pipeline I’ve created.
As per the documentation here, JDBC producers should be able to process binlog data. I’ve used Field remover to only use /Data and /Table fields.
When I run the pipeline I am getting error that input record has no data for <schema>.<table> . How can I create a pipeline to consume binlog records?