Class PartitionConsumeRecord

java.lang.Object

io.confluent.kafkarest.entities.v3.PartitionConsumeRecord

public abstract class PartitionConsumeRecord
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PartitionConsumeRecord.Builder
static class	PartitionConsumeRecord.ExceededFields
static class	PartitionConsumeRecord.Header
static enum	PartitionConsumeRecord.TimestampType

Constructor Summary

Constructors

Constructor	Description
PartitionConsumeRecord()

Method Summary

Modifier and Type	Method	Description
static PartitionConsumeRecord.Builder	builder()
abstract PartitionConsumeRecord.ExceededFields	getExceededFields()
abstract List<PartitionConsumeRecord.Header>	getHeaders()
abstract Object	getKey()
abstract long	getOffset()
abstract int	getPartitionId()
abstract long	getTimestamp()
abstract PartitionConsumeRecord.TimestampType	getTimestampType()
abstract Object	getValue()
static List<PartitionConsumeRecord>	listFromConsumerRecordList(List<org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]>> consumerRecords, Integer messageMaxBytes, boolean returnRawBase64Records)

Methods inherited from class java.lang.Object

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

Constructor Details

PartitionConsumeRecord

public PartitionConsumeRecord()

Method Details

getPartitionId

public abstract int getPartitionId()

getOffset

public abstract long getOffset()

getTimestamp

public abstract long getTimestamp()

getKey

@Nullable
public abstract Object getKey()

getValue

@Nullable
public abstract Object getValue()

getTimestampType

@Nullable
public abstract PartitionConsumeRecord.TimestampType getTimestampType()

getHeaders

public abstract List<PartitionConsumeRecord.Header> getHeaders()

getExceededFields

@Nullable
public abstract PartitionConsumeRecord.ExceededFields getExceededFields()

builder

public static PartitionConsumeRecord.Builder builder()

listFromConsumerRecordList

public static List<PartitionConsumeRecord> listFromConsumerRecordList(List<org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]>> consumerRecords,
 Integer messageMaxBytes,
 boolean returnRawBase64Records)