ConsumerGroup class

Constructors

ConsumerGroup(KafkaSession session, String name)

Properties

hashCode → int

The hash code for this object.

no setter, inherited

name → String

final

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

session → KafkaSession

final

Methods

commitOffsets(List<ConsumerOffset> offsets, int consumerGenerationId, String consumerId) → Future

Commits provided offsets to the server for this consumer group.

fetchOffsets(Map<String, Set<int>> topicPartitions) → Future<List<ConsumerOffset>>

Retrieves offsets of this consumer group from the server.

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

resetOffsetsToEarliest(Map<String, Set<int>> topicPartitions) → Future

resetOffsetsToLatest(Map<String, Set<int>> topicPartitions) → Future

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited