diff options
author | Bogumil Zebek <bogumil.zebek@nokia.com> | 2020-05-08 10:42:03 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2020-05-08 10:42:03 +0000 |
commit | 1337fd3c5452f0836091de285a771832d7f5d005 (patch) | |
tree | 80938a3073b6ba6872258b69ae72061895861d35 /netconfsimulator/src/main/java/org/onap/netconfsimulator/kafka/StoreService.java | |
parent | f1effd9cb84a47302a36035cd62fb42b531f557c (diff) | |
parent | ba170b0a6bf2cc295a58ddbdc8da0cc2f6dbddfd (diff) |
Merge "Fix failing integration test in netconf simulator"
Diffstat (limited to 'netconfsimulator/src/main/java/org/onap/netconfsimulator/kafka/StoreService.java')
-rw-r--r-- | netconfsimulator/src/main/java/org/onap/netconfsimulator/kafka/StoreService.java | 6 |
1 files changed, 5 insertions, 1 deletions
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<String, String> consumerFactory; static final List<String> TOPICS_TO_SUBSCRIBE = Collections.singletonList(CONFIG_TOPIC); @@ -69,6 +70,9 @@ public class StoreService { ConsumerRecords<String, String> 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; } |