org.apache.paimon.flink.action.cdc

Interface MessageQueueSchemaUtils.ConsumerWrapper

All Superinterfaces:

AutoCloseable

Enclosing class:

MessageQueueSchemaUtils

public static interface MessageQueueSchemaUtils.ConsumerWrapper
extends AutoCloseable

Wrap the consumer for different message queues.

Method Summary

Modifier and Type	Method and Description
List<CdcSourceRecord>	getRecords(int pollTimeOutMills)
String	topic()

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

getRecords

List<CdcSourceRecord> getRecords(int pollTimeOutMills)

topic

String topic()