Class SimpleConsumeMultiPartitionRequest.Builder

java.lang.Object

io.confluent.kafkarest.entities.v3.SimpleConsumeMultiPartitionRequest.Builder

Enclosing class:

SimpleConsumeMultiPartitionRequest

public abstract static class SimpleConsumeMultiPartitionRequest.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract SimpleConsumeMultiPartitionRequest	build()
abstract SimpleConsumeMultiPartitionRequest.Builder	setFetchMaxBytes(Integer fetchMaxBytes)
abstract SimpleConsumeMultiPartitionRequest.Builder	setFromBeginning(Boolean fromBeginning)
abstract SimpleConsumeMultiPartitionRequest.Builder	setMaxPollRecords(Integer maxPollRecords)
abstract SimpleConsumeMultiPartitionRequest.Builder	setMessageMaxBytes(Integer messageMaxBytes)
abstract SimpleConsumeMultiPartitionRequest.Builder	setOffsets(List<SimpleConsumeMultiPartitionRequest.PartitionOffset> offsets)
abstract SimpleConsumeMultiPartitionRequest.Builder	setTimestamp(Long timestamp)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

setOffsets

public abstract SimpleConsumeMultiPartitionRequest.Builder setOffsets(List<SimpleConsumeMultiPartitionRequest.PartitionOffset> offsets)

setFromBeginning

public abstract SimpleConsumeMultiPartitionRequest.Builder setFromBeginning(Boolean fromBeginning)

setTimestamp

public abstract SimpleConsumeMultiPartitionRequest.Builder setTimestamp(Long timestamp)

setMaxPollRecords

public abstract SimpleConsumeMultiPartitionRequest.Builder setMaxPollRecords(Integer maxPollRecords)

setFetchMaxBytes

public abstract SimpleConsumeMultiPartitionRequest.Builder setFetchMaxBytes(Integer fetchMaxBytes)

setMessageMaxBytes

public abstract SimpleConsumeMultiPartitionRequest.Builder setMessageMaxBytes(Integer messageMaxBytes)

build

public abstract SimpleConsumeMultiPartitionRequest build()