Interface IStreamPartitioner<K, V>

Namespace

Org.Apache.Kafka.Streams.Processor

Assembly

MASES.KNet.dll

Listener for Kafka StreamPartitioner. Extends IJVMBridgeBase

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

Type Parameters

K

The data associated to the event

V

The data associated to the event

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

Partition(String, K, V, int)

Executes the StreamPartitioner action in the CLR

int Partition(String topic, K key, V value, int numPartitions)

Parameters

topic String

The StreamPartitioner object

key K

The StreamPartitioner object

value V

The StreamPartitioner object

numPartitions int

The StreamPartitioner object

Returns

int

an integer between 0 and numPartitions -1, or -1 if the default partitioning logic should be used

Partitions(String, K, V, int)

Executes the StreamPartitioner action in the CLR

Optional<Set<Integer>> Partitions(String topic, K key, V value, int numPartitions)

Parameters

topic String

The StreamPartitioner object

key K

The StreamPartitioner object

value V

The StreamPartitioner object

numPartitions int

The StreamPartitioner object

Returns

Optional<Set<Integer>>

an Optional of Set of integers between 0 and numPartitions -1, Empty optional means using default partitioner