Table of Contents

Class ConsumerRecords

Namespace
Org.Apache.Kafka.Clients.Consumer
Assembly
MASES.KNet.dll
public class ConsumerRecords : Iterable, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IEnumerable, IEnumerableExtension, IIterable
Inheritance
JVMBridgeBase
JVMBridgeBase<Iterable>
JVMBridgeBaseEnumerable<Iterable>
ConsumerRecords
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
IEnumerableExtension
Inherited Members
JVMBridgeBaseEnumerable<Iterable>.GetEnumerator()
JVMBridgeBase<Iterable>.IsAssignableFrom(IJavaType)
JVMBridgeBase<Iterable>.IsAssignableFrom<T>()
JVMBridgeBase<Iterable>.Execute<T>(params T[])
JVMBridgeBase<Iterable>.DynBridgeClazz
JVMBridgeBase<Iterable>.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.Dispose()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener

Constructors

ConsumerRecords()

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

public ConsumerRecords()

ConsumerRecords(Map)

public ConsumerRecords(Map arg0)

Parameters

arg0 Map

Map

ConsumerRecords(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 ConsumerRecords(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

EMPTY

public static ConsumerRecords EMPTY { get; }

Property Value

ConsumerRecords

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

Count()

public int Count()

Returns

int

int

Empty()

public static ConsumerRecords Empty()

Returns

ConsumerRecords

ConsumerRecords

IsEmpty()

public bool IsEmpty()

Returns

bool

bool

Iterator()

public Iterator Iterator()

Returns

Iterator

Iterator

Partitions()

public Set Partitions()

Returns

Set

Set

Records(String)

public Iterable Records(String arg0)

Parameters

arg0 String

String

Returns

Iterable

Iterable

Records(TopicPartition)

public List Records(TopicPartition arg0)

Parameters

arg0 TopicPartition

TopicPartition

Returns

List

List