Class KafkaStreams
public class KafkaStreams : AutoCloseable, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IAutoCloseable- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AutoCloseable>KafkaStreams
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeBase<AutoCloseable>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])JVMBridgeBase<AutoCloseable>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])JVMBridgeBase<AutoCloseable>.IsAssignableFrom(IJavaType)JVMBridgeBase<AutoCloseable>.IsAssignableFrom<T>()JVMBridgeBase<AutoCloseable>.Execute<T>(params T[])JVMBridgeBase<AutoCloseable>.DynBridgeClazzJVMBridgeBase<AutoCloseable>.BridgeClazzJVMBridgeBase.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.Dispose()JVMBridgeBase.ToString()JVMBridgeBase.GetHashCode()JVMBridgeBase.Notify()JVMBridgeBase.NotifyAll()JVMBridgeBase.Wait()JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeListener
Constructors
KafkaStreams()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public KafkaStreams()KafkaStreams(Topology, Properties)
public KafkaStreams(Topology arg0, Properties arg1)Parameters
arg0Topologyarg1Properties
KafkaStreams(Topology, Properties, Time)
public KafkaStreams(Topology arg0, Properties arg1, Time arg2)Parameters
arg0Topologyarg1Propertiesarg2Time
KafkaStreams(Topology, Properties, KafkaClientSupplier)
public KafkaStreams(Topology arg0, Properties arg1, KafkaClientSupplier arg2)Parameters
arg0Topologyarg1Propertiesarg2KafkaClientSupplier
KafkaStreams(Topology, Properties, KafkaClientSupplier, Time)
public KafkaStreams(Topology arg0, Properties arg1, KafkaClientSupplier arg2, Time arg3)Parameters
arg0Topologyarg1Propertiesarg2KafkaClientSupplierarg3Time
KafkaStreams(Topology, StreamsConfig)
public KafkaStreams(Topology arg0, StreamsConfig arg1)Parameters
arg0Topologyarg1StreamsConfig
KafkaStreams(Topology, StreamsConfig, Time)
public KafkaStreams(Topology arg0, StreamsConfig arg1, Time arg2)Parameters
arg0Topologyarg1StreamsConfigarg2Time
KafkaStreams(Topology, StreamsConfig, KafkaClientSupplier)
public KafkaStreams(Topology arg0, StreamsConfig arg1, KafkaClientSupplier arg2)Parameters
arg0Topologyarg1StreamsConfigarg2KafkaClientSupplier
KafkaStreams(params object[])
Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
public KafkaStreams(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
public override bool IsBridgeStatic { get; }Property Value
Methods
AddStreamThread()
public Optional<String> AddStreamThread()Returns
AllLocalStorePartitionLags()
public Map<String, Map<Integer, LagInfo>> AllLocalStorePartitionLags()Returns
CleanUp()
public void CleanUp()ClientInstanceIds(Duration)
public ClientInstanceIds ClientInstanceIds(Duration arg0)Parameters
Returns
Close()
public void Close()Close(Duration)
public bool Close(Duration arg0)Parameters
Returns
Exceptions
Close(CloseOptions)
public bool Close(KafkaStreams.CloseOptions arg0)Parameters
Returns
Exceptions
IsPaused()
public bool IsPaused()Returns
MetadataForAllStreamsClients()
public Collection<StreamsMetadata> MetadataForAllStreamsClients()Returns
MetadataForLocalThreads()
public Set<ThreadMetadata> MetadataForLocalThreads()Returns
Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>()
public Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric> Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>() where ReturnExtendsOrg_Apache_Kafka_Common_Metric : MetricReturns
- Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric>
Type Parameters
ReturnExtendsOrg_Apache_Kafka_Common_Metric
Pause()
public void Pause()QueryMetadataForKey<K>(String, K, Serializer<K>)
public KeyQueryMetadata QueryMetadataForKey<K>(String arg0, K arg1, Serializer<K> arg2)Parameters
arg0Stringarg1KKarg2Serializer<K>
Returns
Type Parameters
K
QueryMetadataForKey<K, Arg2objectSuperK>(String, K, StreamPartitioner<Arg2objectSuperK, object>)
public KeyQueryMetadata QueryMetadataForKey<K, Arg2objectSuperK>(String arg0, K arg1, StreamPartitioner<Arg2objectSuperK, object> arg2) where Arg2objectSuperK : KParameters
arg0Stringarg1KKarg2StreamPartitioner<Arg2objectSuperK, object>
Returns
Type Parameters
KArg2objectSuperKK
Query<R>(StateQueryRequest<R>)
public StateQueryResult<R> Query<R>(StateQueryRequest<R> arg0)Parameters
arg0StateQueryRequest<R>
Returns
Type Parameters
R
RemoveStreamThread()
public Optional<String> RemoveStreamThread()Returns
RemoveStreamThread(Duration)
public Optional<String> RemoveStreamThread(Duration arg0)Parameters
Returns
Resume()
public void Resume()SetGlobalStateRestoreListener(StateRestoreListener)
public void SetGlobalStateRestoreListener(StateRestoreListener arg0)Parameters
SetStandbyUpdateListener(StandbyUpdateListener)
public void SetStandbyUpdateListener(StandbyUpdateListener arg0)Parameters
SetStateListener(StateListener)
public void SetStateListener(KafkaStreams.StateListener arg0)Parameters
SetUncaughtExceptionHandler(StreamsUncaughtExceptionHandler)
public void SetUncaughtExceptionHandler(StreamsUncaughtExceptionHandler arg0)Parameters
Start()
public void Start()Exceptions
StateMethod()
public KafkaStreams.State StateMethod()Returns
Store<T>(StoreQueryParameters<T>)
public T Store<T>(StoreQueryParameters<T> arg0)Parameters
Returns
- T
T
Type Parameters
T
StreamsMetadataForStore(String)
public Collection<StreamsMetadata> StreamsMetadataForStore(String arg0)