test fixes

kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/MessagesService.java

@@ -86,6 +86,7 @@ public class MessagesService {
               .content(execData.getValue())
               .headers(execData.getHeaders())
               .offset(execData.getOffset())
+              .partition(execData.getPartition())
               .timestamp(
                   Optional.ofNullable(execData.getTimestampMs())
                       .map(ts -> OffsetDateTime.ofInstant(Instant.ofEpochMilli(ts), ZoneOffset.UTC))

kafka-ui-api/src/test/java/com/provectus/kafka/ui/service/MessagesServiceTest.java

@@ -98,18 +98,18 @@ class MessagesServiceTest extends AbstractIntegrationTest {
 
   @Test
   void execSmartFilterTestReturnsExecutionResult() {
-    var executionParams = new SmartFilterTestExecutionDTO()
-        .filterCode("key != null && val != null && headers != null && timestampMs != null && offset != null")
-        .key("key")
-        .value("val")
+    var params = new SmartFilterTestExecutionDTO()
+        .filterCode("key != null && value != null && headers != null && timestampMs != null && offset != null")
+        .key("1234")
+        .value("{ \"some\" : \"value\" } ")
         .headers(Map.of("h1", "hv1"))
         .offset(12345L)
         .timestampMs(System.currentTimeMillis())
         .partition(1);
-    assertThat(execSmartFilterTest(executionParams).getResult()).isTrue();
+    assertThat(execSmartFilterTest(params).getResult()).isTrue();
 
-    executionParams.setFilterCode("return false");
-    assertThat(execSmartFilterTest(executionParams).getResult()).isFalse();
+    params.setFilterCode("return false");
+    assertThat(execSmartFilterTest(params).getResult()).isFalse();
   }
 
   @Test