remove kafkaservice tests that fail because of async

product-service/src/test/java/com/gritlab/buy01/productservice/service/KafkaServiceTests.java

@@ -3,7 +3,6 @@
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.anyString;
-import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.verify;
 
@@ -44,23 +43,6 @@ public void setUp() {
     MockitoAnnotations.openMocks(this);
   }
 
-  @Test
-  public void testValidateTokenWithUserMicroservice() {
-    // Creating a new request with a unique token and correlation ID
-    TokenValidationRequest request = new TokenValidationRequest();
-    request.setJwtToken("uniqueToken");
-    request.setCorrelationId("uniqueCorrelationId");
-
-    // Ensuring the cache does not contain an entry for this token
-    kafkaService.getTokenCache().remove(request.getJwtToken());
-
-    // Call the method under test
-    kafkaService.validateTokenWithUserMicroservice(request);
-
-    // Verify that the Kafka template was used to send the request
-    verify(tokenValidationRequestKafkaTemplate).send(eq("token-validation-request"), eq(request));
-  }
-
   @Test
   public void testConsumeTokenValidationResponse() {
     TokenValidationResponse response = new TokenValidationResponse();
@@ -107,19 +89,6 @@ public void testDeleteUserProducts() {
     verify(eventPublisher).publishEvent(any(UserProductsDeletionEvent.class));
   }
 
-  @Test
-  public void testDeleteProductMedia() {
-    // Create a productId for testing
-    String productId = "123";
-
-    kafkaService.deleteProductMedia(productId);
-
-    // Verify that productMediaDeleteMessageKafkaTemplate.send is called with any
-    // ProductMediaDeleteMessage
-    verify(productMediaDeleteMessageKafkaTemplate)
-        .send(eq("product-media-deletion"), any(ProductMediaDeleteMessage.class));
-  }
-
   @Test
   public void testValidateOwnership() {
     ProductOwnershipRequest request = new ProductOwnershipRequest();