fix: support new params for topic_data handler

Author: Raubzeug

src/containers/Tenant/Diagnostics/TopicData/getData.ts

@@ -66,7 +66,12 @@ export const generateTopicDataGetter = ({
 
         const normalizedOffset = baseOffset + tableOffset;
 
-        const queryParams: TopicDataRequest = {...rest, partition, limit};
+        const queryParams: TopicDataRequest = {
+            ...rest,
+            partition,
+            limit,
+            last_offset: normalizedOffset + limit,
+        };
         queryParams.offset = normalizedOffset;
 
         const response = await window.api.viewer.getTopicData(queryParams);

src/services/api/viewer.ts

@@ -263,10 +263,14 @@ export class ViewerAPI extends BaseYdbAPI {
     }
 
     getTopicData(params: TopicDataRequest, {concurrentId, signal}: AxiosOptions = {}) {
-        return this.get<TopicDataResponse>(this.getPath('/viewer/json/topic_data'), params, {
-            concurrentId,
-            requestConfig: {signal},
-        });
+        return this.get<TopicDataResponse>(
+            this.getPath('/viewer/json/topic_data'),
+            {message_size_limit: '5000', ...params},
+            {
+                concurrentId,
+                requestConfig: {signal},
+            },
+        );
     }
 
     getConsumer(

src/types/api/topic.ts

@@ -172,12 +172,16 @@ export interface TopicDataRequest {
     partition: string;
     /** start offset to read from */
     offset?: number;
+    /** last offset that can possibly be read */
+    last_offset?: number;
     /** min message timestamp to read from */
     read_timestamp?: number;
     /** max number of messages to read (default = 10) */
     limit?: number;
     /** timeout in ms */
     timeout?: number;
+    /** max size of single message (default = 1_000_000 (1 MB)) */
+    message_size_limit?: number;
 }
 
 export interface TopicDataResponse {