diff options
Diffstat (limited to 'testsuites/integration/integration-uservice-test/src')
| -rw-r--r-- | testsuites/integration/integration-uservice-test/src/test/java/org/onap/policy/apex/testsuites/integration/uservice/adapt/kafka/KafkaEventSubscriber.java | 2 |
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 + " ******"); |