From 1a1c877e5020719d537a56e86dd3508a94f486ed Mon Sep 17 00:00:00 2001 From: Sofia Shnaidman Date: Fri, 4 Dec 2020 14:19:17 +0300 Subject: [PATCH] Updated offset parameters for topic messages search. --- .../src/components/Topics/Details/Messages/Messages.tsx | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka-ui-react-app/src/components/Topics/Details/Messages/Messages.tsx b/kafka-ui-react-app/src/components/Topics/Details/Messages/Messages.tsx index 04303c571c..b698572267 100644 --- a/kafka-ui-react-app/src/components/Topics/Details/Messages/Messages.tsx +++ b/kafka-ui-react-app/src/components/Topics/Details/Messages/Messages.tsx @@ -86,7 +86,7 @@ const Messages: React.FC = ({ })); const messageUniqs: FilterProps[] = _.map( _.groupBy(messages, 'partition'), - (v) => _.maxBy(v, 'offset') + (v) => _.minBy(v, 'offset') ).map((v) => ({ offset: v ? v.offset : 0, partition: v ? v.partition : 0, @@ -94,7 +94,7 @@ const Messages: React.FC = ({ return _.map( _.groupBy(_.concat(partitionUniqs, messageUniqs), 'partition'), - (v) => _.maxBy(v, 'offset') as FilterProps + (v) => _.minBy(v, 'offset') as FilterProps ); }, [messages, partitions]);