Class RecordMetadata

Namespace

Org.Apache.Kafka.Clients.Producer

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/producer/RecordMetadata.html

public class RecordMetadata : JVMBridgeBase<RecordMetadata>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<RecordMetadata>

RecordMetadata

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

Constructors

RecordMetadata(IJVMBridgeBaseInitializer)

Initializer used internally by JCOBridge. Do not use directly.

[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public RecordMetadata(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

RecordMetadata(TopicPartition, long, int, long, int, int)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/producer/RecordMetadata.html#%3Cinit%3E(org.apache.kafka.common.TopicPartition,long,int,long,int,int)

public RecordMetadata(TopicPartition arg0, long arg1, int arg2, long arg3, int arg4, int arg5)

Parameters

arg0 TopicPartition

TopicPartition

arg1 long

long

arg2 int

int

arg3 long

long

arg4 int

int

arg5 int

int

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

DateTime

DateTime of Timestamp() or null if HasTimestamp() return false

public DateTime? DateTime { get; }

Property Value

DateTime?

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements java.lang.AutoCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

UNKNOWN_PARTITION

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/producer/RecordMetadata.html#UNKNOWN_PARTITION

public static int UNKNOWN_PARTITION { get; set; }

Property Value

int

Methods

CreatePoolableInstance(TopicPartition, long, int, long, int, int)

HPA initializer for RecordMetadata(Org.Apache.Kafka.Common.TopicPartition arg0, long arg1, int arg2, long arg3, int arg4, int arg5)

public static RecordMetadata CreatePoolableInstance(TopicPartition arg0, long arg1, int arg2, long arg3, int arg4, int arg5)

Parameters

arg0 TopicPartition

arg1 long

arg2 int

arg3 long

arg4 int

arg5 int

Returns

RecordMetadata

HasOffset()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/producer/RecordMetadata.html#hasOffset()

public bool HasOffset()

Returns

bool

bool

HasTimestamp()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/producer/RecordMetadata.html#hasTimestamp()

public bool HasTimestamp()

Returns

bool

bool

Offset()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/producer/RecordMetadata.html#offset()

public long Offset()

Returns

long

long

Partition()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/producer/RecordMetadata.html#partition()

public int Partition()

Returns

int

int

SerializedKeySize()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/producer/RecordMetadata.html#serializedKeySize()

public int SerializedKeySize()

Returns

int

int

SerializedValueSize()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/producer/RecordMetadata.html#serializedValueSize()

public int SerializedValueSize()

Returns

int

int

Timestamp()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/producer/RecordMetadata.html#timestamp()

public long Timestamp()

Returns

long

long

Topic()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/producer/RecordMetadata.html#topic()

public String Topic()

Returns

String

String