# How to use Single Message Transformations (SMTs) kafka connect in OGG KAFKA CONNECT

**URL:** <https://forum.confluent.io/t/how-to-use-single-message-transformations-smts-kafka-connect-in-ogg-kafka-connect/13437>\
**Category:** Self-Managed Connectors\
**Created:** [3 December 2024 06:59 UTC](https://forum.confluent.io/t/how-to-use-single-message-transformations-smts-kafka-connect-in-ogg-kafka-connect/13437 "2024-12-03T06:59:26Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![NhatDuy11](https://sea1.discourse-cdn.com/flex019/user_avatar/forum.confluent.io/nhatduy11/32/4078_2.png) [@NhatDuy11](https://forum.confluent.io/u/NhatDuy11)\
**Post date:** [3 December 2024 06:59 UTC](https://forum.confluent.io/t/how-to-use-single-message-transformations-smts-kafka-connect-in-ogg-kafka-connect/13437/1 "2024-12-03T06:59:26Z")

</div>

I want to find a way to use Single Message Transformation (SMT) in OGG KAFKA CONNECT (Oracle Golden Gate Kafka Connect) but haven’t found a way yet. Can you give me ideas about this problem? Thank you very much.

 ![image](https://us1.discourse-cdn.com/flex019/uploads/confluentcommunity/original/2X/a/aa67262fddea5aa77d4f2c7fbc72661fd8846275.png)

---

<div class="post-metadata">

**Author:** ![vnguyen](https://avatars.discourse-cdn.com/v4/letter/v/c89c15/32.png) [@vnguyen](https://forum.confluent.io/u/vnguyen)\
**Post date:** [5 December 2024 20:45 UTC](https://forum.confluent.io/t/how-to-use-single-message-transformations-smts-kafka-connect-in-ogg-kafka-connect/13437/2 "2024-12-05T20:45:10Z")

</div>

Hello there,

Here is a SMT example on Oracle source with Debezium connector. It should be similar with OGG.  
Look at here for SMT document: [Get started with Single Message Transforms for self-managed connectors | Confluent Documentation](https://docs.confluent.io/platform/current/connect/transforms/overview.html)

```auto
{
  "name": "my-source",
    "config": {
        "connector.class" : "io.debezium.connector.oracle.OracleConnector",
        "advertised.host.name" : "localhost",
        "database.url": "url",
        "database.user" : "user",
        "database.password" : "pass",
        "database.pdb.name" : "pdbname",
        "database.dbname" : "dbname",
        "database.server.name" : "server_name",
        "schema.history.internal.kafka.topic" : "table-history",
        "schema.history.internal.store.only.captured.tables.ddl" : "true",
        "schema.history.internal.skip.unparseable.ddl" : "true",
        "log.mining.strategy" : "online_catalog",
        "table.include.list" : "MY_SCHEMA.MY_TABLE",
        "sanitize.field.names" : "true",
        "time.precision.mode" : "connect",
        "key.converter.schema.registry.url" : "http://schema-registry:8081",
        "value.converter.schema.registry.url" : "http://schema-registry:8081",
        "key.converter" : "io.confluent.connect.avro.AvroConverter",
        "value.converter" : "io.confluent.connect.avro.AvroConverter",
        "key.converter.schemas.enable" : "true",
        "value.converter.schemas.enable" : "true",
        "decimal.handling.mode" : "double",
        "internal.log.mining.query.logs.for.snapshot.offset" : "false",
        "heartbeat.interval.ms" : "9000",
        "errors.tolerance": "all",
        "errors.deadletterqueue.topic.name": "source.errors",
        "errors.deadletterqueue.topic.replication.factor": 1,
        "errors.deadletterqueue.context.headers.enable": true,
        "topic.prefix": "TEST",

        "transforms" : "MyFilters",

        "transforms.MyFilters.type": "io.confluent.connect.transforms.Filter$Value",
        "transforms.MyFilters.filter.condition": "$[?(@ && @.after && @.after.STATUS in ['Open'] && @.after.COMPANY in ['Apple','Tesla'])]",
        "transforms.MyFilters.filter.type": "include", 
        "transforms.MyFilters.missing.or.null.behavior": "exclude",
        "transforms.MyFilters.predicate": "IsMyTable",

        "predicates": "IsMyTable",
        "predicates.IsMyTable.type": "org.apache.kafka.connect.transforms.predicates.TopicNameMatches",
        "predicates.IsMyTable.pattern": ".*MY_TABLE"
    }
}

```