StreamingMetricsMXBean (Debezium Connector Common 3.6.0.Final API)

All Superinterfaces:: SchemaMetricsMXBean

All Known Subinterfaces:: StreamingChangeEventSourceMetricsMXBean

All Known Implementing Classes:: DefaultStreamingChangeEventSourceMetrics, StreamingMeter

public interface StreamingMetricsMXBean extends SchemaMetricsMXBean

Exposes streaming metrics.

Method Summary

Modifier and Type

Method

Description

String

getLastTransactionId()

long

getMilliSecondsBehindSource()

long

getNumberOfCommittedTransactions()

long

getNumberOfUnchangedEventsSkipped()

Map<String,String>

getSourceEventPosition()

void

resetLagBehindSource()

Methods inherited from interface io.debezium.pipeline.metrics.traits.SchemaMetricsMXBean
getCapturedTables

Method Details
- getSourceEventPosition
  
  Map<String,String> getSourceEventPosition()
- getMilliSecondsBehindSource
  
  long getMilliSecondsBehindSource()
- getNumberOfCommittedTransactions
  
  long getNumberOfCommittedTransactions()
- getLastTransactionId
  
  String getLastTransactionId()
- resetLagBehindSource
  
  void resetLagBehindSource()
- getNumberOfUnchangedEventsSkipped
  
  long getNumberOfUnchangedEventsSkipped()