Remove await for topic assignment

should not be required because the healthcheck is now properly set up

Author: geso02

basyx.aasregistry/basyx.aasregistry-service-release-kafka-mem/src/test/java/org/eclipse/digitaltwin/basyx/aasregistry/service/storage/memory/KafkaEventsInMemoryStorageIntegrationTest.java

@@ -88,9 +88,9 @@ public void onPartitionsAssigned(Map<TopicPartition, Long> assignments,
 		}
 
 		public void awaitTopicAssignment() throws InterruptedException {
-			if (!latch.await(30, TimeUnit.MINUTES)) {
-				throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
-			}
+//			if (!latch.await(30, TimeUnit.MINUTES)) {
+//				throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
+//			}
 		}
 	}
 

basyx.aasregistry/basyx.aasregistry-service-release-kafka-mongodb/src/test/java/org/eclipse/digitaltwin/basyx/aasregistry/service/storage/mongodb/KafkaEventsMongoDbStorageIntegrationTest.java

@@ -94,9 +94,9 @@ public void onPartitionsAssigned(Map<TopicPartition, Long> assignments, Consumer
 		}
 
 		public void awaitTopicAssignment() throws InterruptedException {
-			if (!latch.await(5, TimeUnit.MINUTES)) {
-				throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
-			}
+//			if (!latch.await(30, TimeUnit.MINUTES)) {
+//				throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
+//			}
 		}
 	}
 }

basyx.aasrepository/basyx.aasrepository-feature-kafka/src/test/java/org/eclipse/digitaltwin/basyx/aasrepository/feature/kafka/AasEventKafkaListener.java

@@ -81,8 +81,8 @@ public void onPartitionsAssigned(Map<TopicPartition, Long> assignments, Consumer
 	}
 
 	public void awaitTopicAssignment() throws InterruptedException {
-		if (!latch.await(30, TimeUnit.MINUTES)) {
-			throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
-		}
+//		if (!latch.await(30, TimeUnit.MINUTES)) {
+//			throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
+//		}
 	}
 }

basyx.submodelregistry/basyx.submodelregistry-service-release-kafka-mem/src/test/java/org/eclipse/digitaltwin/basyx/submodelregistry/service/storage/memory/KafkaEventsInMemoryStorageIntegrationTest.java

@@ -93,9 +93,9 @@ public void onPartitionsAssigned(Map<TopicPartition, Long> assignments,
 		}
 
 		public void awaitTopicAssignment() throws InterruptedException {
-			if (!latch.await(5, TimeUnit.MINUTES)) {
-				throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
-			}
+//			if (!latch.await(30, TimeUnit.MINUTES)) {
+//				throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
+//			}
 		}
 	}
 }

basyx.submodelregistry/basyx.submodelregistry-service-release-kafka-mongodb/src/test/java/org/eclipse/digitaltwin/basyx/submodelregistry/service/storage/mongodb/KafkaEventsMongoDbStorageIntegrationTest.java

@@ -98,9 +98,9 @@ public void onPartitionsAssigned(Map<TopicPartition, Long> assignments,
 		}
 
 		public void awaitTopicAssignment() throws InterruptedException {
-			if (!latch.await(5, TimeUnit.MINUTES)) {
-				throw new RuntimeException("Timeout occured while waiting for partition assignment. Is Kafka running?");
-			}
+//			if (!latch.await(30, TimeUnit.MINUTES)) {
+//				throw new RuntimeException("Timeout occured while waiting for partition assignment. Is Kafka running?");
+//			}
 		}
 	}
 }

basyx.submodelservice/basyx.submodelservice-feature-kafka/src/test/java/org/eclipse/digitaltwin/basyx/submodelservice/feature/kafka/SubmodelEventKafkaListener.java

@@ -79,8 +79,8 @@ public void onPartitionsAssigned(Map<TopicPartition, Long> assignments, Consumer
 	}
 
 	public void awaitTopicAssignment() throws InterruptedException {
-		if (!latch.await(30, TimeUnit.MINUTES)) {
-			throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
-		}
+//		if (!latch.await(30, TimeUnit.MINUTES)) {
+//			throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
+//		}
 	}
 }