issues/650: clean up

Author: DimaVilda

api/src/test/java/io/kafbat/ui/AbstractIntegrationTest.java

@@ -87,7 +87,7 @@ public void initialize(@NotNull ConfigurableApplicationContext context) {
       } catch (FileNotFoundException e) {
         throw new RuntimeException(e);
       }
-      System.setProperty("kafka.clusters.0.serde.0.properties.protobufMessageName", "test.Main");
+      System.setProperty("kafka.clusters.0.serde.0.properties.protobufMessageName", "test.MessageWithAny");
 
       // List unavailable hosts to verify failover
       System.setProperty("kafka.clusters.0.schemaRegistry",

api/src/test/java/io/kafbat/ui/service/MessagesServiceTest.java

@@ -10,14 +10,10 @@
 import io.kafbat.ui.model.KafkaCluster;
 import io.kafbat.ui.model.PollingModeDTO;
 import io.kafbat.ui.model.SmartFilterTestExecutionDTO;
-import io.kafbat.ui.model.SmartFilterTestExecutionResultDTO;
 import io.kafbat.ui.model.TopicMessageDTO;
 import io.kafbat.ui.model.TopicMessageEventDTO;
 import io.kafbat.ui.producer.KafkaTestProducer;
-import io.kafbat.ui.serdes.builtin.Int32Serde;
-import io.kafbat.ui.serdes.builtin.Int64Serde;
 import io.kafbat.ui.serdes.builtin.ProtobufFileSerde;
-import io.kafbat.ui.serdes.builtin.ProtobufRawSerde;
 import io.kafbat.ui.serdes.builtin.StringSerde;
 import java.util.HashSet;
 import java.util.List;
@@ -26,16 +22,13 @@
 import java.util.UUID;
 import java.util.concurrent.atomic.AtomicReference;
 import org.apache.kafka.clients.admin.NewTopic;
-import org.apache.kafka.clients.producer.RecordMetadata;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.CsvSource;
-import org.openapitools.jackson.nullable.JsonNullable;
 import org.springframework.beans.factory.annotation.Autowired;
 import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
 
 class MessagesServiceTest extends AbstractIntegrationTest {
@@ -226,9 +219,9 @@ void execSmartFilterTestReturnsErrorOnFilterCompilationError() {
   void sendMessageWithProtobufAnyType() {
     String jsonContent = """
         {
-          "name": "testFromSpringApp",
+          "name": "testName",
           "payload": {
-            "@type": "type.googleapis.com/test.Referenced",
+            "@type": "type.googleapis.com/test.PayloadMessage",
             "id": "123"
           }
         }

api/src/test/resources/protobuf-serde/main.proto renamed to api/src/test/resources/protobuf-serde/messagewithany.proto

@@ -3,11 +3,11 @@ package test;
 
 import "google/protobuf/any.proto";
 
-message Main {
+message MessageWithAny  {
     string name = 1;
     google.protobuf.Any payload = 2;
 }
 
-message Referenced {
+message PayloadMessage  {
     string id = 1;
 }