Oracle CDC source connector

Hi,

I am using https://www.confluent.io/hub/confluentinc/kafka-connect-oracle-cdc. I don’t want to take all the columns for tables. I went through the documentation but I could find inclusion and exclusion property which helps to filter table. Can this connector filter columns also? Where I can find the configuration for the same?

Thank you.

Look at the ReplaceField Single Message Transform (SMT); there is an field exclusion list.

Also if you are on 2.6+ you can leverage predicates to allow for different replace filter rules based on a matching predicate (https://issues.apache.org/jira/browse/KAFKA-9673).

Here’s a nice video and article I did about it :slight_smile:

2 Likes

Hey, thank you so much. Let me try it out.