Table of Contents

Class StreamPartitioner

Namespace
Org.Apache.Kafka.Streams.Processor
Assembly
MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StreamPartitioner.html

public class StreamPartitioner : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<JVMBridgeListener>
JVMBridgeListener
StreamPartitioner
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Derived
Inherited Members
JVMBridgeListener.Dispose()
JVMBridgeListener.AutoInit
JVMBridgeListener.IsBridgeStatic
JVMBridgeListener.IsBridgeCloseable
JVMBridgeListener.IsBridgeListener
JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)
JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()
JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])
JVMBridgeBase<JVMBridgeListener>.DynBridgeClazz
JVMBridgeBase<JVMBridgeListener>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeInterface
JVMBridgeBase.IsBridgeAbstract

Constructors

StreamPartitioner()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public StreamPartitioner()

Properties

BridgeClassName

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeListener_BridgeClassName.htm

public override string BridgeClassName { get; }

Property Value

string

OnPartitions

Handler for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StreamPartitioner.html#partitions-java.lang.String-java.lang.Object-java.lang.Object-int-

public Func<String, object, object, int, Optional> OnPartitions { get; set; }

Property Value

Func<String, object, object, int, Optional>

Remarks

If OnPartitions has a value it takes precedence over corresponding class method

Methods

InitializeHandlers()

Handlers initializer for StreamPartitioner

protected virtual void InitializeHandlers()

Partitions(String, object, object, int)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StreamPartitioner.html#partitions-java.lang.String-java.lang.Object-java.lang.Object-int-

public virtual Optional Partitions(String arg0, object arg1, object arg2, int arg3)

Parameters

arg0 String

String

arg1 object

object

arg2 object

object

arg3 int

int

Returns

Optional

Optional

Remarks

The method invokes the default implementation in the JVM interface using PartitionsDefault(String, object, object, int); override the method to implement a different behavior

PartitionsDefault(String, object, object, int)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StreamPartitioner.html#partitions-java.lang.String-java.lang.Object-java.lang.Object-int-

public Optional PartitionsDefault(String arg0, object arg1, object arg2, int arg3)

Parameters

arg0 String

String

arg1 object

object

arg2 object

object

arg3 int

int

Returns

Optional

Optional

Remarks

The method invokes the default implementation in the JVM interface

Edit this page