Interface PartitionAssignmentReceiver (1.13.8)

Version 1.13.8

• 1.15.0 (latest)
• 1.14.8
• 1.13.8
• 1.12.22
• 1.11.2
• 1.10.0
• 1.9.4
• 1.8.0
• 1.7.1
• 1.6.3
• 1.5.5
• 1.4.12

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
Name	Description
assignment	Set<Partition>