Class ConnectedAssignerImpl (1.6.1)

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

Inheritance

java.lang.Object > SingleConnection > ConnectedAssignerImpl

Implements

ConnectedAssigner

Methods

ack()

public void ack()

handleInitialResponse(PartitionAssignment response)

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

handleStreamResponse(PartitionAssignment response)

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