Interface ControlledModeOrBuilder (0.12.0)

Version latest

• 0.12.0 (latest)
• 0.11.0
• 0.10.0
• 0.9.0
• 0.8.0
• 0.6.0
• 0.5.0
• 0.4.0
• 0.3.0
• 0.2.0
• 0.1.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.