[GitHub] [pulsar] mingfang commented on issue #4672: [Kafka connect] Transformations are not working

[GitBox <gi...@apache.org>]

mingfang commented on issue #4672:
URL: https://github.com/apache/pulsar/issues/4672#issuecomment-713263029


   It appears that transforms are not working in general.
   This is my config and I'm not seeing transforms working.
   I'm also not seeing errors.  It is as if transforms are ignored completely.
   
   ```
   tenant: "public"
   namespace: "default"
   name: "debezium-postgres-source"
   topicName: "debezium-postgres-topic"
   archive: "connectors/pulsar-io-debezium-postgres-2.6.1.nar"
   parallelism: 1
   
   configs:
   
       database.hostname: "worker-0.worker.citus-example"
       database.port: "5432"
       database.user: "postgres"
       database.password: "postgres"
       database.dbname: "postgres"
       database.server.name: "dbserver1"
       schema.whitelist: "public"
       plugin.name: "pgoutput"
   
       pulsar.service.url: "pulsar://localhost:6650"
   
       transforms: "reroute"
       transforms.reroute.type: "io.debezium.transforms.ByLogicalTableRouter"
       transforms.reroute.topic.regex: ".*"
       transforms.reroute.topic.replacement: "foo"
       transforms.reroute.key.enforce.uniqueness: "false"
   ```


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org