fix(server): improving search and listing due to higher timeout and max.poll.records

[jonasvoelcker]

fixes https://github.com/tchiotludo/akhq/issues/1834

[AlexisSouquiere]

I think we should add the matchesCount increment and break in the records loop (like in the search function) in the consumeOldest and consumeNewest functions to prevent iterating over the possible 25K records if we have our topic-data.size number of messages returned by the poll.

It will replace this https://github.com/tchiotludo/akhq/blob/20691454de7bccc7c110843db205c972275ed463/src/main/java/org/akhq/repositories/RecordRepository.java#L178

that is done too late for me. I quickly tested locally and by doing that I'm improving the iteration number from 3k (number of records given by poll) to 50 (because there is no filters applied in my case so I just want the fist 50 records)

WDYT ?

[jonasvoelcker]

Hi @AlexisSouquiere,

maybe we could override the max.poll.records for the normal listings with the page size, I'll test it tomorrow whether this leads to a valid pagination or not ;)

[jonasvoelcker]

Hey @AlexisSouquiere,

I tested a lot and it is enough to use the page-size as max.poll.records. I also left the limit inside the stream api in place so there is no way to output more entries then desired. The "after" gets calculated in the Controller not the RecordRepository so the limit also effects the pagination.

[AlexisSouquiere]

Sounds good ! 👌

There is one thing that I figured out during the tests that I will address in another PR. But it's not linked to these changes. Oldest sort can show different messages if you refresh the page several times and maybe don't show the real oldest messages. We are using a single consumer with all the partitions assigned and depending on which partition answers first, we will show these messages. But one the same request, the next time another partition can answer faster so it will show different messages. Order is guaranteed in a partition but not accros partition. I started to switch from a single consumer with all the partition assigned to a consumer by partition to get to "real" oldest messages.

But as I said it's not linked to this PR !

[jonasvoelcker]

Hey @AlexisSouquiere,

I can also see the same problem on my test topic, that's really creepy :(

[jonasvoelcker]

@AlexisSouquiere That's weird, after my last change there is a newly created topic present ^^

[jonasvoelcker]

Hi @tchiotludo, @AlexisSouquiere,

do you plan to provide a 0.25.1 anytime soon? Unfortunately we are still kind of blocked in our searches.

Best Regards Jonas

[tchiotludo]

yes this is the plan to release before my holidays end of next week :+1: