FetchRequest class
Kafka FetchRequest.
- Inheritance
-
- Object
- KafkaRequest
- FetchRequest
Constructors
- FetchRequest(int maxWaitTime, int minBytes)
- Creates new instance of FetchRequest.
Properties
- apiKey → int
-
API key of FetchRequest
final
- apiVersion → int
-
API version of FetchRequest
final
- correlationId → int
-
finalinherited
- hashCode → int
-
The hash code for this object.
no setterinherited
- maxWaitTime → int
-
Maximum amount of time in milliseconds to block waiting if insufficient
data is available at the time the request is issued.
final
- minBytes → int
-
Minimum number of bytes of messages that must be available
to give a response.
final
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
Methods
-
add(
String topicName, int partitionId, int fetchOffset, [int maxBytes = 65536]) → void -
Adds
topicNamewithparitionIdto this FetchRequest.fetchOffsetdefines the offset to begin this fetch from. -
createResponse(
List< int> data) → dynamic -
override
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
toBytes(
) → List< int> -
override
-
toString(
) → String -
A string representation of this object.
override
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited