From 9fe87260dad83647fc451bbf84bdd3678d03dd44 Mon Sep 17 00:00:00 2001 From: Mgrdich Date: Mon, 26 Dec 2022 15:52:00 +0400 Subject: [PATCH] Filters Fixing the seekTo parameter when all the partitions are selected --- .../Topics/Topic/Messages/Filters/Filters.tsx | 27 ++++++++++--------- 1 file changed, 15 insertions(+), 12 deletions(-) diff --git a/kafka-ui-react-app/src/components/Topics/Topic/Messages/Filters/Filters.tsx b/kafka-ui-react-app/src/components/Topics/Topic/Messages/Filters/Filters.tsx index 096a714c4ee..08e4aed6912 100644 --- a/kafka-ui-react-app/src/components/Topics/Topic/Messages/Filters/Filters.tsx +++ b/kafka-ui-react-app/src/components/Topics/Topic/Messages/Filters/Filters.tsx @@ -231,18 +231,21 @@ const Filters: React.FC = ({ props.seekType = SeekType.TIMESTAMP; } - props.seekTo = selectedPartitions.map(({ value }) => { - const offsetProperty = - seekDirection === SeekDirection.FORWARD ? 'offsetMin' : 'offsetMax'; - const offsetBasedSeekTo = - currentOffset || partitionMap[value][offsetProperty]; - const seekToOffset = - currentSeekType === SeekType.OFFSET - ? offsetBasedSeekTo - : timestamp?.getTime(); - - return `${value}::${seekToOffset || '0'}`; - }); + if (selectedPartitions.length !== partitions.length) { + // not everything in the partition is selected + props.seekTo = selectedPartitions.map(({ value }) => { + const offsetProperty = + seekDirection === SeekDirection.FORWARD ? 'offsetMin' : 'offsetMax'; + const offsetBasedSeekTo = + currentOffset || partitionMap[value][offsetProperty]; + const seekToOffset = + currentSeekType === SeekType.OFFSET + ? offsetBasedSeekTo + : timestamp?.getTime(); + + return `${value}::${seekToOffset || '0'}`; + }); + } } const newProps = omitBy(props, (v) => v === undefined || v === '');