john1337 opened a new issue, #15171:
URL: https://github.com/apache/pulsar/issues/15171
**Describe the bug**
i am using pulsar's delay message feature,when i increate message count to
10000,consumer will only get 5000 messages or so ,other messages were lost,1000
delay message deliver worked well.
producer code:
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
for(int i=0;i<10000;i++){
producer.createMessage("clicks2","hello world"+sdf.format(new
Date()))
.deliverAfter(1L, TimeUnit.MINUTES).sendAsync();
}
consumer code:
private AtomicInteger count = new AtomicInteger(0);
@PulsarConsumer(topic="clicks2",subscriptionType=
SubscriptionType.Shared,clazz=String.class)
public void consume(String msg) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
log.info("msg:{},收到数据时间:{}",msg,sdf.format(new Date()));
int total = count.incrementAndGet();
log.info("总共收到数据量:{}",total);
}
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
