public interface ControlledModeOrBuilder extends MessageOrBuilderImplements
MessageOrBuilderMethods
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. |