Sink from one topic to multiple tables having one pk

Kafka Connect
1

I am trying to delete rows from one topic to multiple tables.

JDBC Sink Connector

Transforms:dropValueSchema
dropValueSchema.schema.behavior:force_optional
table.name.format: Table1, Table2
pk.mode:record_key
pk.fields:PM
delete.enabled:true

I am getting connector failure error:

Table "Table1, Table2" is missing and auto-creation is disabled

Note: Table1 and Table2 are already in the database. I have created an individual connector to delete the rows. it works amazingly. but I wanted to reduce the number of connectors.

2

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.