BatchEnvelope class
Envelope for message batches used by Consumer.batchConsume.
Constructors
Properties
- commitMetadata ↔ String
-
getter/setter pair
- hashCode → int
-
The hash code for this object.
no setterinherited
-
items
→ List<
MessageEnvelope> -
final
-
offsetsToCommit
→ Iterable<
ConsumerOffset> -
no setter
-
result
→ Future<
_ProcessingResult> -
no setter
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
Methods
-
ack(
) → void - Signals that batch has been processed and we are ready for the next one. This method will not trigger offset commit if this envelope has been created by a high-level Consumer.
-
cancel(
) → void - Signals to consumer to cancel any further deliveries and close the stream.
-
commit(
String metadata) → void - Signals that batch has been processed and it's offsets can be committed. In case if consumerGroup functionality is not used (like in the Fetcher) then this method's behaviour will be the same as in ack method.
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited