void setUp()

in ddm-notification-service/src/it/java/com/epam/digital/data/platform/notification/BaseKafkaIT.java [47:52]

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

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