The consumer should be able to pick up the new partitions automatically. If auto.offset.reset is set to the largest, the consumer may miss some data in the new partitions. To avoid data loss, you have to set auto.offset.reset to smallest.
Thanks, Jun On Thu, Nov 28, 2013 at 12:28 PM, Yu, Libo <libo...@citi.com> wrote: > Hi team, > > I am reading this link: > > https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools#Replicationtools-5.AddPartitionTool > and this JIRA https://issues.apache.org/jira/i#browse/KAFKA-1030. I have > a couple of questions. > > After adding a partition by using the tool, should the consumer processes > be restarted? If auto.offset.reset > is set to the largest for my consumer processes, will be it changed during > partition addition? And is there > chance of message loss? Thanks. > > > > Regards, > > Libo > >
