Class ConnectedAssignerImpl (1.12.22)

public class ConnectedAssignerImpl extends SingleConnection<PartitionAssignmentRequest,PartitionAssignment,PartitionAssignment> implements ConnectedAssigner

Inheritance

java.lang.Object > SingleConnection > ConnectedAssignerImpl

Implements

ConnectedAssigner

Methods

ack()

public void ack()

handleStreamResponse(PartitionAssignment response)

protected void handleStreamResponse(PartitionAssignment response)
Parameter
NameDescription
responsePartitionAssignment
Overrides
Exceptions
TypeDescription
CheckedApiException