public static interface MessageQueueSchemaUtils.ConsumerWrapper extends AutoCloseable
Modifier and Type | Method and Description |
---|---|
List<CdcSourceRecord> |
getRecords(int pollTimeOutMills) |
String |
topic() |
close
List<CdcSourceRecord> getRecords(int pollTimeOutMills)
String topic()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.