consumerGroup method

ConsumerGroup<T> consumerGroup()

Creates a ConsumerGroup that automatically trims the log when all consumers have pulled the earliest offset.

Implementation

ConsumerGroup<T> consumerGroup() {
  if (retention > -1) {
    throw StateError('retention should be -1 for ConsumerGroup usage');
  }

  return ConsumerGroup(this);
}