Jdbc sink connector

Kafka Connect
1

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.

2

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.

3

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

4

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

1 Like
5

Thank you for sharing @rmoff

6

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