File tree Expand file tree Collapse file tree 1 file changed +9
-4
lines changed
kafka-ui-react-app/src/components/Topics/Topic/Details/Messages Expand file tree Collapse file tree 1 file changed +9
-4
lines changed Original file line number Diff line number Diff line change @@ -39,10 +39,11 @@ const MessagesTable: React.FC = () => {
3939 return { offset : 0 , partition : parseInt ( partition , 10 ) } ;
4040 } ) ;
4141
42+ const seekDirection = searchParams . get ( 'seekDirection' ) ;
43+ const isBackward = seekDirection === SeekDirection . BACKWARD ;
44+
4245 const messageUniqs = map ( groupBy ( messages , 'partition' ) , ( v ) =>
43- searchParams . get ( 'seekDirection' ) === SeekDirection . BACKWARD
44- ? minBy ( v , 'offset' )
45- : maxBy ( v , 'offset' )
46+ isBackward ? minBy ( v , 'offset' ) : maxBy ( v , 'offset' )
4647 ) . map ( ( message ) => ( {
4748 offset : message ?. offset || 0 ,
4849 partition : message ?. partition || 0 ,
@@ -54,7 +55,11 @@ const MessagesTable: React.FC = () => {
5455 ( v ) => maxBy ( v , 'offset' )
5556 )
5657 )
57- . map ( ( { offset, partition } ) => `${ partition } ::${ offset } ` )
58+ . map ( ( { offset, partition } ) => {
59+ const offsetQuery = isBackward ? offset : offset + 1 ;
60+
61+ return `${ partition } ::${ offsetQuery } ` ;
62+ } )
5863 . join ( ',' ) ;
5964
6065 searchParams . set ( 'seekTo' , nextSeekTo ) ;
You can’t perform that action at this time.
0 commit comments