Class ConnectedAssignerImpl (1.16.5)

1.16.5 (latest) 1.16.2 1.15.21 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 class ConnectedAssignerImpl extends SingleConnection<PartitionAssignmentRequest,PartitionAssignment,PartitionAssignment> implements ConnectedAssigner

Inheritance

java.lang.Object > SingleConnection > ConnectedAssignerImpl

Implements

ConnectedAssigner

Inherited Members

SingleConnection.close()

SingleConnection.handleStreamResponse(StreamResponseT)

SingleConnection.initialize(StreamRequestT)

SingleConnection.onComplete()

SingleConnection.onError(Throwable)

SingleConnection.onResponse(StreamResponseT)

SingleConnection.onStart(StreamController)

SingleConnection.sendToClient(ClientResponseT)

SingleConnection.sendToStream(StreamRequestT)

SingleConnection.setError(CheckedApiException)

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

ack()

public void ack()

handleStreamResponse(PartitionAssignment response)

protected void handleStreamResponse(PartitionAssignment response)

Parameter
Name	Description
response	PartitionAssignment

Overrides

SingleConnection<StreamRequestT,StreamResponseT,ClientResponseT>.handleStreamResponse(StreamResponseT response)

Exceptions
Type	Description
CheckedApiException