MessageEnvelope class
Envelope for a Message used by high-level consumer.
Constructors
- MessageEnvelope(String topicName, int partitionId, int offset, Message message)
- Creates new envelope.
Properties
- hashCode → int
-
The hash code for this object.
no setterinherited
- message → Message
-
Actual message received from Kafka broker.
final
- offset → int
-
This message's offset
final
- partitionId → int
-
Partition ID of this message.
final
-
result
→ Future<
_ProcessingResult> -
no setter
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
- topicName → String
-
Topic name of this message.
final
Methods
-
ack(
) → void - Signals that message 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 message has been processed and it's offset can be committed (in case of high-level Consumer implementation). 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