Naveen, This is certainly something that should be configurable. Currently, it is always using the value of "smallest".
I have created a ticket to make this configurable in the Processor: https://issues.apache.org/jira/browse/NIFI-1146 <https://issues.apache.org/jira/browse/NIFI-1146> Thanks -Mark > On Nov 10, 2015, at 1:55 PM, Madhire, Naveen <[email protected]> > wrote: > > Hi, > > I want to get all the records from Kafka topic and hence setting > “auto.offset.reset” to “smallest” to fetch the data from topic. > > I am getting the below error when I add “auto.offset.reset” kafka property in > the list of processor properties, > > > “auto.offset.reset” validated against “smallest” is invalid because > “auto.offset.reset” is not a supported property. > > > Is there any other way or I am doing something wrong? > > > Thanks, > Naveen > > > > The information contained in this e-mail is confidential and/or proprietary > to Capital One and/or its affiliates and may only be used solely in > performance of work or services for Capital One. The information transmitted > herewith is intended only for use by the individual or entity to which it is > addressed. If the reader of this message is not the intended recipient, you > are hereby notified that any review, retransmission, dissemination, > distribution, copying or other use of, or taking of any action in reliance > upon this information is strictly prohibited. If you have received this > communication in error, please contact the sender and delete the material > from your computer.
