Interface ITimestampExtractor

Namespace

Org.Apache.Kafka.Streams.Processor

Assembly

MASES.KNet.dll

Listener for Kafka TimestampExtractor. Extends IJVMBridgeBase

public interface ITimestampExtractor : IJVMBridgeBase, IJVMBridgeDefinition

Inherited Members

IJVMBridgeBase.MonitorEnter()

IJVMBridgeBase.MonitorExit()

IJVMBridgeBase.IsInstanceOf(string)

IJVMBridgeBase.IsInstanceOf(IJavaType)

IJVMBridgeBase.IsInstanceOf<T>()

IJVMBridgeBase.RuntimeIsInstanceOf<T>()

IJVMBridgeBase.CastTo<TNewClass>()

IJVMBridgeBase.CastDirect<TNewClass>()

IJVMBridgeBase.DynBridgeInstance

IJVMBridgeBase.BridgeInstance

IJVMBridgeDefinition.BridgeClassName

IJVMBridgeDefinition.IsBridgeInterface

IJVMBridgeDefinition.IsBridgeAbstract

IJVMBridgeDefinition.IsBridgeStatic

IJVMBridgeDefinition.IsBridgeCloseable

IJVMBridgeDefinition.IsBridgeListener

Methods

Extract(ConsumerRecord<object, object>, long)

Executes the TimestampExtractor action in the CLR

long Extract(ConsumerRecord<object, object> record, long partitionTime)

Parameters

record ConsumerRecord<object, object>

a data record

partitionTime long

the highest extracted valid timestamp of the current record's partition˙ (could be -1 if unknown)

Returns

long

the timestamp of the record