consumerGroup method
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);
}