Class ConnectedAssignerImpl (1.10.0)

Version 1.10.0

• 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 class ConnectedAssignerImpl extends SingleConnection<PartitionAssignmentRequest,PartitionAssignment,PartitionAssignment> implements ConnectedAssigner

Inheritance

java.lang.Object > SingleConnection > ConnectedAssignerImpl

Implements

ConnectedAssigner

Inherited Members

SingleConnection.close()

SingleConnection.handleInitialResponse(StreamResponseT)

SingleConnection.handleStreamResponse(StreamResponseT)

SingleConnection.initialize(StreamRequestT)

SingleConnection.isCompleted()

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()

handleInitialResponse(PartitionAssignment response)

protected void handleInitialResponse(PartitionAssignment response)

Parameter

Name	Description
response	PartitionAssignment

Overrides

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

Exceptions

Type	Description
CheckedApiException

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