Hi, If you want to reset the consumer offset (I am not sure about the group's offset) you can use this property in 0.9.0 props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
2015-12-29 16:35 GMT+01:00 Han JU <ju.han.fe...@gmail.com>: > Hi Stevo, > > But by deleting and recreating the topic, do I remove also the messages > ingested? > My use case is that I ingest prepared messages once and run consumer tests > multiple times, between each test run I reset the consumer group's offset > so that each run starts from the beginning and consumers all the messages. > > 2015-12-29 16:19 GMT+01:00 Stevo Slavić <ssla...@gmail.com>: > > > Have you considered deleting and recreating topic used in test? > > Once topic is clean, read/poll once - any committed offset should be > > outside of the range, and consumer should reset offset. > > > > On Tue, Dec 29, 2015 at 4:11 PM, Han JU <ju.han.fe...@gmail.com> wrote: > > > > > Hello, > > > > > > For local test purpose I need to frequently reset offset for a consumer > > > group. In 0.8 I just delete the consumer group's zk node under > > > `/consumers`. But with the redesign of the 0.9, how could I achieve the > > > same thing? > > > > > > Thanks! > > > > > > -- > > > *JU Han* > > > > > > Software Engineer @ Teads.tv > > > > > > +33 0619608888 > > > > > > > > > -- > *JU Han* > > Software Engineer @ Teads.tv > > +33 0619608888 >
