Class SimpleConsumeMultiPartitionRequest

java.lang.Object

io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest

public abstract class SimpleConsumeMultiPartitionRequest
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SimpleConsumeMultiPartitionRequest.Builder
static class	SimpleConsumeMultiPartitionRequest.PartitionOffset

Constructor Summary

Constructors

Constructor	Description
SimpleConsumeMultiPartitionRequest()

Method Summary

Modifier and Type	Method	Description
static SimpleConsumeMultiPartitionRequest.Builder	builder()
abstract Integer	getFetchMaxBytes()
abstract Boolean	getFromBeginning()
abstract Integer	getMaxPollRecords()
abstract Integer	getMessageMaxBytes()
abstract List<SimpleConsumeMultiPartitionRequest.PartitionOffset>	getOffsets()
abstract Long	getTimestamp()

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleConsumeMultiPartitionRequest

public SimpleConsumeMultiPartitionRequest()

Method Details

getOffsets

@Nullable
public abstract List<SimpleConsumeMultiPartitionRequest.PartitionOffset> getOffsets()

getFromBeginning

@Nullable
public abstract Boolean getFromBeginning()

getTimestamp

@Nullable
public abstract Long getTimestamp()

getMaxPollRecords

@Nullable
public abstract Integer getMaxPollRecords()

getFetchMaxBytes

@Nullable
public abstract Integer getFetchMaxBytes()

getMessageMaxBytes

@Nullable
public abstract Integer getMessageMaxBytes()

builder

public static SimpleConsumeMultiPartitionRequest.Builder builder()