Package io.debezium.pipeline.source.spi

Interface EventMetadataProvider

public interface EventMetadataProvider
An interface implemented by each connector that enables metrics metadata to be extracted from an event.
Author:
Jiri Pechanec

  • Method Details

    • getEventTimestamp

      Instant getEventTimestamp(io.debezium.spi.schema.DataCollectionId source, OffsetContext offset, Object key, org.apache.kafka.connect.data.Struct value)
      Returns:
      source event timestamp

    • getEventSourcePosition

      Map<String,String> getEventSourcePosition(io.debezium.spi.schema.DataCollectionId source, OffsetContext offset, Object key, org.apache.kafka.connect.data.Struct value)
      Returns:
      one or more values uniquely position the event in the transaction log - e.g. LSN

    • getTransactionId

      String getTransactionId(io.debezium.spi.schema.DataCollectionId source, OffsetContext offset, Object key, org.apache.kafka.connect.data.Struct value)
      Returns:
      unique identifier of the transaction to which the event belongs

    • toSummaryString

      default String toSummaryString(io.debezium.spi.schema.DataCollectionId source, OffsetContext offset, Object key, org.apache.kafka.connect.data.Struct value)
      Returns:
      s String that describes the event

    • getTransactionInfo

      default TransactionInfo getTransactionInfo(io.debezium.spi.schema.DataCollectionId source, OffsetContext offset, Object key, org.apache.kafka.connect.data.Struct value)