Is there any API to get the Debezium backlog?

Solution Verified - Updated -

Issue

When insert/update/delete data in DB for 10 records, environment have issue but Debezium database connector is still running, then send event to kafka topic will be delay. if Debezium connector check 4 DB operation records and send event to topic, then 6 DB operation records are pending in Debezium, then pending records in 6, no need to restart connector, just wait for a while and then can receive the rest 6 messages, I want to know is there any API to get the Debezium backlog? ie: to get the pending 6 records?

Environment

  • Red Hat build of Debezium 2.5.4

Subscriber exclusive content

A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.

Current Customers and Partners

Log in for full access

Log In

New to Red Hat?

Learn more about Red Hat subscriptions

Using a Red Hat product through a public cloud?

How to access this content