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

使用TopicPartition的程序包

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

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

返回变量类型为TopicPartition的类型的com.taosdata.jdbc.common中的方法

限定符和类型	方法和说明
Map<TopicPartition,Long>	Consumer.beginningOffsets(String topic)
Map<TopicPartition,Long>	Consumer.endOffsets(String topic)
Map<TopicPartition,Long>	Consumer.position(String topic)

参数类型为TopicPartition的com.taosdata.jdbc.common中的方法

限定符和类型	方法和说明
long	Consumer.position(TopicPartition partition)
void	Consumer.seek(TopicPartition partition, long offset) If this API is invoked for the same partition more than once, the latest offset will be used on the next poll().

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

返回变量类型为TopicPartition的类型的com.taosdata.jdbc.tmq中的方法

限定符和类型	方法和说明
Map<TopicPartition,Long>	TaosConsumer.beginningOffsets(String topic)
Map<TopicPartition,Long>	JNIConsumer.beginningOffsets(String topic)
Map<TopicPartition,Long>	TaosConsumer.endOffsets(String topic)
Map<TopicPartition,Long>	JNIConsumer.endOffsets(String topic)
Map<TopicPartition,Long>	TaosConsumer.position(String topic)
Map<TopicPartition,Long>	JNIConsumer.position(String topic)

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

限定符和类型	方法和说明
List<ConsumerRecord<V>>	ConsumerRecords.get(TopicPartition partition)
long	TaosConsumer.position(TopicPartition tp)
long	JNIConsumer.position(TopicPartition partition)
void	ConsumerRecords.put(TopicPartition tp, ConsumerRecord<V> r)
void	TaosConsumer.seek(TopicPartition partition, long offset)
void	JNIConsumer.seek(TopicPartition partition, long offset)

类型变量类型为TopicPartition的com.taosdata.jdbc.tmq中的构造器参数

构造器和说明
ConsumerRecords(Map<TopicPartition,List<ConsumerRecord<V>>> records)

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

返回变量类型为TopicPartition的类型的com.taosdata.jdbc.ws.tmq中的方法

限定符和类型	方法和说明
Map<TopicPartition,Long>	WSConsumer.beginningOffsets(String topic)
Map<TopicPartition,Long>	WSConsumer.endOffsets(String topic)
Map<TopicPartition,Long>	WSConsumer.position(String topic)

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

限定符和类型	方法和说明
long	WSConsumer.position(TopicPartition partition)
void	WSConsumer.seek(TopicPartition partition, long offset)