Interface PartitionAssignmentReceiver (1.11.1)

public interface PartitionAssignmentReceiver

A receiver for partition assignments. All updates to reflect the assignment should be performed inline.

Methods

handleAssignment(Set<Partition> assignment)

public abstract void handleAssignment(Set<Partition> assignment)
Parameter
NameDescription
assignmentSet<Partition>