public interface ApplicationState
Modifier and Type | Method and Description |
---|---|
Map<TaskId,TaskInfo> |
allTasks() |
AssignmentConfigs |
assignmentConfigs() |
Map<ProcessId,KafkaStreamsState> |
kafkaStreamsStates(boolean computeTaskLags) |
Map<ProcessId,KafkaStreamsState> kafkaStreamsStates(boolean computeTaskLags)
computeTaskLags
- whether to include task lag information in the returned metadata. Note that passing
in "true" will result in a remote call to fetch changelog topic end offsets, and you should pass in "false" unless
you specifically need the task lag information.processId
to KafkaStreamsState
for all KafkaStreams clients in this appTaskAssignmentException
- if a retriable error occurs while computing KafkaStreamsState metadata. Re-throw
this exception to have Kafka Streams retry the rebalance by returning the same
assignment and scheduling an immediate followup rebalanceAssignmentConfigs assignmentConfigs()