Skip to content

Commit 594652a

Browse files
authored
Tries to fix problem with kafka not ready
1 parent 538aa69 commit 594652a

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

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

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ public void onPartitionsAssigned(Map<TopicPartition, Long> assignments, Consumer
8181
}
8282

8383
public void awaitTopicAssignment() throws InterruptedException {
84-
if (!latch.await(5, TimeUnit.MINUTES)) {
84+
if (!latch.await(60, TimeUnit.MINUTES)) {
8585
throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
8686
}
8787
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ public void onPartitionsAssigned(Map<TopicPartition, Long> assignments, Consumer
7979
}
8080

8181
public void awaitTopicAssignment() throws InterruptedException {
82-
if (!latch.await(5, TimeUnit.MINUTES)) {
82+
if (!latch.await(60, TimeUnit.MINUTES)) {
8383
throw new RuntimeException("Timeout occured while waiting for partition assignment. Is kafka running?");
8484
}
8585
}

0 commit comments

Comments
 (0)