Jdbc sink connector

Hi Team,

Just wanted to know is there any setting that is available to check the number of messages that are consumed from a topic in a Jdbc sink connector.

How to ensure how many records are consumed from a topic so that we can notify producer.

The connector is ingesting a stream, so “how many” isn’t an easy question to answer compared to a batch ingest.

You could use ksqlDB or Kafka Streams to do a windowed aggregation over the topic that the connector writes to.

Thank you @rmoff . Could you please provide an example for the same if any.

Here’s a relevant part of a video I made:

1 Like

Thank you for sharing @rmoff