public class KafkaStreamsAssignment extends Object
Modifier and Type | Class and Description |
---|---|
static class |
KafkaStreamsAssignment.AssignedTask |
Modifier and Type | Method and Description |
---|---|
void |
assignTask(KafkaStreamsAssignment.AssignedTask newTask) |
Optional<Instant> |
followupRebalanceDeadline() |
static KafkaStreamsAssignment |
of(ProcessId processId,
Set<KafkaStreamsAssignment.AssignedTask> assignment)
Construct an instance of KafkaStreamsAssignment with this processId and the given set of
assigned tasks.
|
ProcessId |
processId() |
void |
removeTask(KafkaStreamsAssignment.AssignedTask removedTask) |
Map<TaskId,KafkaStreamsAssignment.AssignedTask> |
tasks() |
String |
toString() |
KafkaStreamsAssignment |
withFollowupRebalance(Instant rebalanceDeadline)
This API can be used to request that a followup rebalance be triggered by the KafkaStreams client
receiving this assignment.
|
public static KafkaStreamsAssignment of(ProcessId processId, Set<KafkaStreamsAssignment.AssignedTask> assignment)
withFollowupRebalance(Instant)
API.processId
- the processId for the KafkaStreams client that should receive this assignmentassignment
- the set of tasks to be assigned to this KafkaStreams clientpublic KafkaStreamsAssignment withFollowupRebalance(Instant rebalanceDeadline)
rebalanceDeadline
- the instant after which this KafkaStreams client will trigger a followup rebalancepublic ProcessId processId()
ProcessID
associated with this KafkaStreamsAssignment
public Map<TaskId,KafkaStreamsAssignment.AssignedTask> tasks()
KafkaStreamsAssignment
public void assignTask(KafkaStreamsAssignment.AssignedTask newTask)
public void removeTask(KafkaStreamsAssignment.AssignedTask removedTask)
public Optional<Instant> followupRebalanceDeadline()