You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by "hengheng0haha@163.com" <he...@163.com> on 2016/06/24 09:51:01 UTC

issue in SimpleConsumerDemo

hi,
I got an issue when i run SimpleConsumerDemo(source:kafka/examples/src/main/java/kafka/examples/SimpleConsumerDemo.java)
I only got 2 messages when i set fetchSize to 100.

thanks!



hengheng0haha@163.com

Re: issue in SimpleConsumerDemo

Posted by Guozhang Wang <wa...@gmail.com>.

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, hengheng0haha@163.com <
hengheng0haha@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!
>
> ------------------------------
> hengheng0haha@163.com
>



-- 
-- Guozhang