[ https://issues.apache.org/jira/browse/KAFKA-18018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Abhinav Dixit resolved KAFKA-18018. ----------------------------------- Resolution: Later > Consumption degrading when using DefaultStatePersister for 1 million records > of size 1KB > ---------------------------------------------------------------------------------------- > > Key: KAFKA-18018 > URL: https://issues.apache.org/jira/browse/KAFKA-18018 > Project: Kafka > Issue Type: Sub-task > Reporter: Abhinav Dixit > Assignee: Abhinav Dixit > Priority: Major > > I was running some performance tests and I couldn't consume 1,000,000 records > using 10 share consumers. I've narrowed down the issue to > {{DefaultStatePersister}} . When I run the same tests using > {{{}NoOpShareStatePersister{}}}, then I don't see the reliability issue. > Steps to reproduce (could be maybe reproduced by other ways as well, but this > is how I noticed it consistently) - # Create a topic with a single partition > # Produce 1000 records into the topic and consume it with the help of 10 > share consumers. > # Again produce 1000 records into the topic and consume it with the help of > 10 share consumers. > # Produce 1,000,000 records into the topic and consume it with the help of > 10 share consumers. > You'll see the records not getting consumed even within 5 minutes (It > shouldn't take more than 5-6 seconds to consume 1,000,000 records with 10 > share consumers, based on my past experience) > PS - I haven't noticed any issues using console share consumers, so probably > an issue with scale -- This message was sent by Atlassian Jira (v8.20.10#820010)