luxun icon indicating copy to clipboard operation
luxun copied to clipboard

Published 20 hours ago • verified publisher icon bulldog2011

IndexOutOfBoundsException while combining async producer and SimpleConsumer

Open pprun opened this issue 10 years ago • 0 comments

Steps:

  1. 10K send by a producer with props.put("producer.type", "async");
  2. try to consume by index simpleConsumer1.consume("test-topic", index, 1024); in bounded while loop
  3. after the the first iteration, it failed with: Exception in thread "main" java.lang.IndexOutOfBoundsException at com.leansoft.luxun.common.exception.ErrorMapper.toException(ErrorMapper.java:34) at com.leansoft.luxun.consumer.SimpleConsumer.consume(SimpleConsumer.java:86)

pprun avatar May 27 '14 13:05 pprun