Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Metric NameData TypeDescriptionMBean
topic-countintThe current number of topics for synchronization.kafka.mirror.connect:type=MirrorSourceConnector,source={source}
partition-countintThe current number of partitions per topic for synchronization.kafka.mirror.connect:type=MirrorSourceConnector,source={source},topic={topic}
consumer-group-countintThe current number of consumer group for synchronization.kafka.mirror.connect:type=MirrorCheckpointConnector,source={source}
consumer-group-offsetlongThe latest synchronized offset of consumer group.kafka.mirror.connect:type=MirrorCheckpointConnector,source={source},group={group}
consumer-group-offset-translation-laglongThe lag of offsets in difference upstream offset between offset sync and consumer group.kafka.mirror.connect:type=MirrorCheckpointConnector,source={source},group={group}
consumer-group-offset-translation-error-countintThe number of error offset translation.kafka.mirror.connect:type=MirrorCheckpointConnector,source={source},group={group}
checkpoint-task-startup-time-avglongThe average time, in milliseconds, that the checkpoint task takes from start to stop.kafka.mirror.connect:type=MirrorCheckpointConnector,source={source}
checkpoint-task-startup-time-maxlongThe maximum time, in milliseconds, that the checkpoint task takes from start to stop.kafka.mirror.connect:type=MirrorCheckpointConnector,source={source}
background-job-success-countintThe number of background job success execution.

kafka.mirror.connect:type=MirrorSourceConnector,source={source},job={job}

kafka.mirror.connect:type=MirrorCheckpointConnector,source={source},job={job}

background-job-failure-countintThe number of background job failure execution.

kafka.mirror.connect:type=MirrorSourceConnector,source={source},job={job}

kafka.mirror.connect:type=MirrorCheckpointConnector,source={source},job={job}

background-task-execution-time-avglongThe duration of background job execution.

kafka.mirror.connect:type=MirrorSourceConnector,source={source},job={job}

kafka.mirror.connect:type=MirrorCheckpointConnector,source={source},job={job}

background-task-execution-time-maxlongThe duration of background job execution.

kafka.mirror.connect:type=MirrorSourceConnector,source={source},job={job}

kafka.mirror.connect:type=MirrorCheckpointConnector,source={source},job={job}

...