You would do this manually with the ConsumerGroupCommand (which also allows you to do deletion of offsets just by topic).
-Ewen On Thu, May 19, 2016 at 4:16 PM, James Cheng <[email protected]> wrote: > I know that when offsets get stored in Kafka, they get cleaned up based on > the offsets.retention.minutes config setting. This happens when using the > new consumer, or when using the old consumer but offsets.storage=kafka. > > If using the old consumer where offsets are stored in Zookeeper, do old > offsets ever get removed? > > Thanks, > -James > > -- Thanks, Ewen
