public interface KafkaStreamsState
Modifier and Type | Method and Description |
---|---|
Map<String,String> |
clientTags()
The client tags for this KafkaStreams client, if set any have been via configs using the
StreamsConfig.clientTagPrefix(java.lang.String) |
SortedSet<String> |
consumerClientIds() |
Optional<HostInfo> |
hostInfo()
The
HostInfo of this KafkaStreams client, if set via the
application.server config |
long |
lagFor(TaskId task)
Returns the total lag across all logged stores in the task.
|
int |
numProcessingThreads()
Returns the number of processing threads available to work on tasks for this KafkaStreams client,
which represents its overall capacity for work relative to other KafkaStreams clients.
|
SortedSet<TaskId> |
previousActiveTasks() |
SortedSet<TaskId> |
previousStandbyTasks() |
SortedSet<TaskId> |
prevTasksByLag(String consumerClientId) |
ProcessId |
processId() |
Optional<String> |
rackId() |
Map<TaskId,Long> |
statefulTasksToLagSums()
Returns a collection containing all (and only) stateful tasks in the topology by
TaskId ,
mapped to its "offset lag sum". |
ProcessId processId()
int numProcessingThreads()
SortedSet<String> consumerClientIds()
SortedSet<TaskId> previousActiveTasks()
SortedSet<TaskId> previousStandbyTasks()
long lagFor(TaskId task)
UnsupportedOperationException
- if the user did not request task lags be computed.SortedSet<TaskId> prevTasksByLag(String consumerClientId)
UnsupportedOperationException
- if the user did not request task lags be computed.Map<TaskId,Long> statefulTasksToLagSums()
TaskId
,
mapped to its "offset lag sum". This is computed as the difference between the changelog end offset
and the current offset, summed across all logged state stores in the task.UnsupportedOperationException
- if the user did not request task lags be computed.Optional<HostInfo> hostInfo()
HostInfo
of this KafkaStreams client, if set via the
application.server
configOptional.empty()
Map<String,String> clientTags()
StreamsConfig.clientTagPrefix(java.lang.String)
Can be used however you want, or passed in to enable the rack-aware standby task assignor.
StreamsConfig
Optional<String> rackId()
Optional.empty()
if none was configured