From ba170b0a6bf2cc295a58ddbdc8da0cc2f6dbddfd Mon Sep 17 00:00:00 2001 From: Bartosz Gardziejewski Date: Thu, 30 Apr 2020 14:44:07 +0200 Subject: Fix failing integration test in netconf simulator Issue-ID: INT-1535 Signed-off-by: Bartosz Gardziejewski Change-Id: I75ec965ea580d96386c74834f146af4c7e44feca --- .../src/main/java/org/onap/netconfsimulator/kafka/StoreService.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'netconfsimulator/src/main/java/org') diff --git a/netconfsimulator/src/main/java/org/onap/netconfsimulator/kafka/StoreService.java b/netconfsimulator/src/main/java/org/onap/netconfsimulator/kafka/StoreService.java index 6bd8390..8f0f0cf 100644 --- a/netconfsimulator/src/main/java/org/onap/netconfsimulator/kafka/StoreService.java +++ b/netconfsimulator/src/main/java/org/onap/netconfsimulator/kafka/StoreService.java @@ -33,13 +33,14 @@ import java.time.Instant; import java.util.ArrayList; import java.util.Collections; import java.util.List; +import java.util.NoSuchElementException; @Slf4j @Service public class StoreService { private static final String CONFIG_TOPIC = "config"; - private static final long CONSUMING_DURATION_IN_MS = 1000; + private static final long CONSUMING_DURATION_IN_MS = 5000; private ConsumerFactory consumerFactory; static final List TOPICS_TO_SUBSCRIBE = Collections.singletonList(CONFIG_TOPIC); @@ -69,6 +70,9 @@ public class StoreService { ConsumerRecords consumerRecords = pollConsumerRecords(consumer); consumerRecords.forEach(consumerRecord -> messages.add(new Message(consumerRecord.timestamp(), consumerRecord.value()))); + } catch (NoSuchElementException e) { + log.warn("not able to create consumer and to poll messages"); + return Collections.emptyList(); } return messages; } -- cgit 1.2.3-korg