Package org.odpi.openmetadata.adapters.eventbus.topic.kafka

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 Summary

Constructors

Constructor	Description
KafkaIncomingEvent(String json, long offset)	Constructor

Method Summary

Modifier and Type	Method	Description
long	getOffset()	Gets the kafka offset of this message

Methods inherited from class org.odpi.openmetadata.repositoryservices.connectors.openmetadatatopic.IncomingEvent

addAsyncProcessingResult, getCreationTime, getJson, getMessageId, hasTimeElapsedSinceCreation, isFullyProcessed, setState

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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