ConsumerGroupExtension<T> extension

on

• OffsetIterator<T>

Methods

consumerGroup() → ConsumerGroup<T>

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