Hi,
I want to ingest messages that are sent by 3rd parties into our system. The ingestion process is as follows: - verify message content - forward invalid messages to ingestion_failure topic - persist valid messages in PostgreSQL - forward messages that have been persisted to ingestion_success topic The last point is key: Only forward messages to ingestion_successful if they have been persisted in PostgreSQL. Is there any way I can do that with a JDBC sink connector? I'm basically looking for the counterpart of the Dead Letter Queue for records that have been processed successfully by the connector. If that's beyond the scope of connectors: Any recommendations on how to do that any other way? Thanks Florian
