summaryrefslogtreecommitdiffstats
path: root/testsuites/integration/integration-uservice-test/src/test
diff options
context:
space:
mode:
Diffstat (limited to 'testsuites/integration/integration-uservice-test/src/test')
-rw-r--r--testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java
index 1c33289b7..54ee9ba92 100644
--- a/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java
+++ b/testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java
@@ -84,7 +84,7 @@ public class KafkaEventSubscriber implements Runnable {
while (subscriberThread.isAlive() && !subscriberThread.isInterrupted()) {
try {
- final ConsumerRecords<String, String> records = consumer.poll(POLL_DURATION);
+ final ConsumerRecords<String, String> records = consumer.poll(POLL_DURATION.toMillis());
for (final ConsumerRecord<String, String> record : records) {
eventsReceivedCount++;
System.out.println("****** Received event No. " + eventsReceivedCount + " ******");