Interface ITopicNameExtractor<K, V>

Namespace

Org.Apache.Kafka.Streams.Processor

Assembly

MASES.KNet.dll

Listener for Kafka TopicNameExtractor. Extends ITopicNameExtractor

public interface ITopicNameExtractor<K, V> : ITopicNameExtractor, IJVMBridgeBase, IJVMBridgeDefinition

Type Parameters

K

V

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(K, V, RecordContext)

Executes the TopicNameExtractor action in the CLR

String Extract(K key, V value, RecordContext recordContext)

Parameters

key K

the record key

value V

the record value

recordContext RecordContext

current context metadata of the record

Returns

String

the topic name this record should be sent to