com.opendxl.databus.common

Class RecordMetadata

java.lang.Object

com.opendxl.databus.common.RecordMetadata

public class RecordMetadata
extends java.lang.Object

The metadata for a record that has been acknowledged by the server An object of this class is built only for Databus as a result of a #send( com.opendxl.streaming.nativeclient.producer.ProducerRecord, com.opendxl.streaming.nativeclient.producer.Callback) method

Constructor Summary

Constructors

Constructor and Description
RecordMetadata(org.apache.kafka.clients.producer.RecordMetadata recordMetadata)

Method Summary

Modifier and Type	Method and Description
long	offset()
int	partition()
java.lang.String	topic()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RecordMetadata

public RecordMetadata(org.apache.kafka.clients.producer.RecordMetadata recordMetadata)

Parameters:

recordMetadata - record metadata

Method Detail

offset

public long offset()

topic

public java.lang.String topic()

partition

public int partition()