Class KafkaIncomingEvent

java.lang.Object
org.odpi.openmetadata.repositoryservices.connectors.openmetadatatopic.IncomingEvent
org.odpi.openmetadata.adapters.eventbus.topic.kafka.KafkaIncomingEvent

public class KafkaIncomingEvent extends IncomingEvent
IncomingEvent that came from Kafka
  • Constructor Details

    • KafkaIncomingEvent

      public KafkaIncomingEvent(String json, long offset)
      Constructor
      Parameters:
      json - message content
      offset - the kafka offset of the message
  • Method Details

    • getOffset

      public long getOffset()
      Gets the kafka offset of this message
      Returns:
      offset