Fetcher class
Message Fetcher.
Main difference to Consumer is that this class does not store it's state in consumer metadata.
It will fetch all messages starting from specified topicOffsets. If no limit is set it will run forever consuming all incoming messages.
Constructors
-
Fetcher(KafkaSession session, List<
TopicOffset> topicOffsets)
Properties
- hashCode → int
-
The hash code for this object.
no setterinherited
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
- session → KafkaSession
-
Instance of Kafka session.
final
-
topicOffsets
→ List<
TopicOffset> -
Offsets to start from.
final
Methods
-
fetch(
{int limit = -1}) → Stream< MessageEnvelope> - Consumes messages from Kafka topics.
-
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