Interface ControlledModeOrBuilder (0.10.0) 

public interface ControlledModeOrBuilder extends MessageOrBuilder

Implements

MessageOrBuilder

Methods

getFallbackStartingOffset()

public abstract String getFallbackStartingOffset()

This is the logical starting point to fallback upon should the specified starting offset be unavailable.

This can be one of the following values:

"begin": This will read from the earliest available message.

"end": This will read only future messages.

string fallback_starting_offset = 2;

Returns
Type Description
String

The fallbackStartingOffset.

getFallbackStartingOffsetBytes()

public abstract ByteString getFallbackStartingOffsetBytes()

This is the logical starting point to fallback upon should the specified starting offset be unavailable.

This can be one of the following values:

"begin": This will read from the earliest available message.

"end": This will read only future messages.

string fallback_starting_offset = 2;

Returns
Type Description
ByteString

The bytes for fallbackStartingOffset.

getStartingLogicalOffset()

public abstract String getStartingLogicalOffset()

This can be set to the following logical starting points:

"begin": This will read from the earliest available message.

"most-recent": This will read from the latest available message.

"end": This will read only future messages.

"stored": This will resume reads one past the last committed offset. It is the only option that resumes progress; all others jump unilaterally.

string starting_logical_offset = 1;

Returns
Type Description
String

The startingLogicalOffset.

getStartingLogicalOffsetBytes()

public abstract ByteString getStartingLogicalOffsetBytes()

This can be set to the following logical starting points:

"begin": This will read from the earliest available message.

"most-recent": This will read from the latest available message.

"end": This will read only future messages.

"stored": This will resume reads one past the last committed offset. It is the only option that resumes progress; all others jump unilaterally.

string starting_logical_offset = 1;

Returns
Type Description
ByteString

The bytes for startingLogicalOffset.

getStartingOffsetCase()

public abstract ControlledMode.StartingOffsetCase getStartingOffsetCase()
Returns
Type Description
ControlledMode.StartingOffsetCase

hasStartingLogicalOffset()

public abstract boolean hasStartingLogicalOffset()

This can be set to the following logical starting points:

"begin": This will read from the earliest available message.

"most-recent": This will read from the latest available message.

"end": This will read only future messages.

"stored": This will resume reads one past the last committed offset. It is the only option that resumes progress; all others jump unilaterally.

string starting_logical_offset = 1;

Returns
Type Description
boolean

Whether the startingLogicalOffset field is set.