Instaclustr Kafka Connect SLA sink plugin

Menu

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:

12
34
54
12
…..

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

FREE TRIAL

Spin up a cluster in less
than 5 minutes.
(No credit card required)

Sign Up Now
Close

Site by Swell Design Group