}
}
- @Test
- void clear() {
-
- }
-
@Test
void testKafka() throws InterruptedException {
waitForKafkaListener();
while (kafkaReceiver.count < NO_OF_OBJECTS) {
logger.info("sleeping {}", kafkaReceiver.count);
- Thread.sleep(1000 * 1);
+ Thread.sleep(1000); //NOSONAR
}
String rec = kafkaReceiver.lastValue();