Did you run it multiple times, and did not clean the committed offsets? This may be a common root cause of seeing fewer messages.
Guozhang On Fri, Jun 24, 2016 at 2:51 AM, hengheng0h...@163.com < hengheng0h...@163.com> wrote: > hi, > I got an issue when i run SimpleConsumerDemo(source:kafka > <https://github.com/apache/kafka>/examples > <https://github.com/apache/kafka/tree/trunk/examples>/src > <https://github.com/apache/kafka/tree/trunk/examples/src>/main > <https://github.com/apache/kafka/tree/trunk/examples/src/main>/java > <https://github.com/apache/kafka/tree/trunk/examples/src/main/java>/kafka > <https://github.com/apache/kafka/tree/trunk/examples/src/main/java/kafka>/ > examples > <https://github.com/apache/kafka/tree/trunk/examples/src/main/java/kafka/examples> > /SimpleConsumerDemo.java) > I only got 2 messages when i set fetchSize to 100. > > thanks! > > ------------------------------ > hengheng0h...@163.com > -- -- Guozhang
