类的使用
com.taosdata.jdbc.tmq.ConsumerRecords

使用ConsumerRecords的程序包

程序包	说明
com.taosdata.jdbc.common
com.taosdata.jdbc.tmq
com.taosdata.jdbc.ws.tmq

com.taosdata.jdbc.common中ConsumerRecords的使用

返回ConsumerRecords的com.taosdata.jdbc.common中的方法

限定符和类型	方法和说明
ConsumerRecords<V>	Consumer.poll(Duration timeout, Deserializer<V> deserializer) get result records

com.taosdata.jdbc.tmq中ConsumerRecords的使用

声明为ConsumerRecords的com.taosdata.jdbc.tmq中的字段

限定符和类型	字段和说明
static ConsumerRecords<?>	ConsumerRecords.EMPTY

返回ConsumerRecords的com.taosdata.jdbc.tmq中的方法

限定符和类型	方法和说明
static <T> ConsumerRecords<T>	ConsumerRecords.emptyRecord()
ConsumerRecords<V>	TaosConsumer.poll(Duration timeout)
ConsumerRecords<V>	JNIConsumer.poll(Duration timeout, Deserializer<V> deserializer)

参数类型为ConsumerRecords的com.taosdata.jdbc.tmq中的方法

限定符和类型	方法和说明
void	OffsetCommitCallback.onComplete(ConsumerRecords<V> records, Exception exception)

参数类型为ConsumerRecords的com.taosdata.jdbc.tmq中的构造器

构造器和说明
OffsetWaitCallback(ConsumerRecords<V> cRecord, JNIConsumer<?> consumer, OffsetCommitCallback<V> callback)

com.taosdata.jdbc.ws.tmq中ConsumerRecords的使用

返回ConsumerRecords的com.taosdata.jdbc.ws.tmq中的方法

限定符和类型	方法和说明
ConsumerRecords<V>	WSConsumer.poll(Duration timeout, Deserializer<V> deserializer)