Instaclustr Kafka Connect SLA sink plugin

This plugin’s purpose is to generate a latency value per each record it receives from the configured topics and write it out to a file in milliseconds.

Example output in a file:


You can use this output to get a view of how much latency exists from when a message was produced to the point at which it was processed by the connector task, using the Kafka record timestamp (assuming it was not manually set and is configured to CreateTime).

Configurations Available
  • “topics” : the topics that are being consumed from
  • “tasks.max” :the number of tasks
  • “file” : the output file the latencies are written to
Example Connector Creation Request

Need Support
Learn More

Already have an account?
Login to the Console

Experiencing difficulties on the website or console?
Status page for known incidents

Don’t have an account yet?
Sign up for a free trial

Why sign up?
To experience the ease of creating and managing clusters via the Instaclustr Console.