T- Type of the consuming record
@Experimental public interface ExternalSystemDataReader<T> extends AutoCloseable
|Modifier and Type||Method and Description|
Poll a batch of records from external system.
List<T> poll(java.time.Duration timeout)
Test cases will keep invoking this method until expected records have been polled, so it's not necessary to fetch all records in one poll, but records should not be duplicated across multiple invocations.
timeout- The maximum time to block
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.