public void setUp()

in src/it/java/com/epam/digital/data/platform/bphistory/persistence/BaseKafkaIT.java [58:63]

• 6 lines of code
• 2 McCabe index (conditional complexity)

  public void setUp() {
    for (var messageListenerContainer : kafkaListenerEndpointRegistry.getListenerContainers()) {
      ContainerTestUtils.waitForAssignment(messageListenerContainer,
          embeddedKafkaBroker.getPartitionsPerTopic());
    }
  }