## Uses of Class
com.taosdata.jdbc.tmq.TopicPartition

Packages that use TopicPartition
com.taosdata.jdbc.common
com.taosdata.jdbc.tmq
com.taosdata.jdbc.ws.tmq
com.taosdata.jdbc.ws.tmq.entity

### Uses of TopicPartition in com.taosdata.jdbc.common

Methods in com.taosdata.jdbc.common that return types with arguments of type TopicPartition
`Set<TopicPartition>` Consumer.`assignment()` Get the set of partitions currently assigned to this consumer.
`Map<TopicPartition,Long>` Consumer.`beginningOffsets(String topic)`
`Map<TopicPartition,OffsetAndMetadata>` Consumer.`committed(Set<TopicPartition> partitions)`
`Map<TopicPartition,Long>` Consumer.`endOffsets(String topic)`
`Map<TopicPartition,Long>` Consumer.`position(String topic)`

Methods in com.taosdata.jdbc.common with parameters of type TopicPartition
`OffsetAndMetadata` Consumer.`committed(TopicPartition partition)` Get the last committed offset for the given partition.
`long` Consumer.`position(TopicPartition partition)` Get the offset of the next record that will be fetched.
`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().

Method parameters in com.taosdata.jdbc.common with type arguments of type TopicPartition
`void` Consumer.`commitAsync(Map<TopicPartition,OffsetAndMetadata> offsets, OffsetCommitCallback<V> callback)`
`void` Consumer.`commitSync(Map<TopicPartition,OffsetAndMetadata> offsets)`
`Map<TopicPartition,OffsetAndMetadata>` Consumer.`committed(Set<TopicPartition> partitions)`
`void` Consumer.`seekToBeginning(Collection<TopicPartition> partitions)`
`void` Consumer.`seekToEnd(Collection<TopicPartition> partitions)`

### Uses of TopicPartition in com.taosdata.jdbc.tmq

Methods in com.taosdata.jdbc.tmq that return types with arguments of type TopicPartition
`Set<TopicPartition>` JNIConsumer.`assignment()`
`Set<TopicPartition>` TaosConsumer.`assignment()`
`Map<TopicPartition,Long>` JNIConsumer.`beginningOffsets(String topic)`
`Map<TopicPartition,Long>` TaosConsumer.`beginningOffsets(String topic)`
`Map<TopicPartition,OffsetAndMetadata>` JNIConsumer.`committed(Set<TopicPartition> partitions)`
`Map<TopicPartition,OffsetAndMetadata>` TaosConsumer.`committed(Set<TopicPartition> partitions)`
`Map<TopicPartition,Long>` JNIConsumer.`endOffsets(String topic)`
`Map<TopicPartition,Long>` TaosConsumer.`endOffsets(String topic)`
`Set<TopicPartition>` ConsumerRecords.`partitions()` Get the partitions which have records contained in this record set.
`Map<TopicPartition,Long>` JNIConsumer.`position(String topic)`
`Map<TopicPartition,Long>` TaosConsumer.`position(String topic)`

Methods in com.taosdata.jdbc.tmq with parameters of type TopicPartition
`OffsetAndMetadata` JNIConsumer.`committed(TopicPartition partition)`
`OffsetAndMetadata` TaosConsumer.`committed(TopicPartition partition)`
`List<ConsumerRecord<V>>` ConsumerRecords.`get(TopicPartition partition)`
`long` JNIConsumer.`position(TopicPartition partition)`
`long` TaosConsumer.`position(TopicPartition tp)`
`void` ConsumerRecords.`put(TopicPartition tp, ConsumerRecord<V> r)`
`void` JNIConsumer.`seek(TopicPartition partition, long offset)`
`void` TaosConsumer.`seek(TopicPartition partition, long offset)`

Method parameters in com.taosdata.jdbc.tmq with type arguments of type TopicPartition
`void` JNIConsumer.`commitAsync(Map<TopicPartition,OffsetAndMetadata> offsets, OffsetCommitCallback<V> callback)`
`void` TaosConsumer.`commitAsync(Map<TopicPartition,OffsetAndMetadata> offsets, OffsetCommitCallback<V> callback)`
`void` JNIConsumer.`commitSync(Map<TopicPartition,OffsetAndMetadata> offsets)`
`void` TaosConsumer.`commitSync(Map<TopicPartition,OffsetAndMetadata> offsets)`
`Map<TopicPartition,OffsetAndMetadata>` JNIConsumer.`committed(Set<TopicPartition> partitions)`
`Map<TopicPartition,OffsetAndMetadata>` TaosConsumer.`committed(Set<TopicPartition> partitions)`
`void` OffsetCommitCallback.`onComplete(Map<TopicPartition,OffsetAndMetadata> offsets, Exception exception)`
`void` JNIConsumer.`seekToBeginning(Collection<TopicPartition> partitions)`
`void` TaosConsumer.`seekToBeginning(Collection<TopicPartition> partitions)`
`void` JNIConsumer.`seekToEnd(Collection<TopicPartition> partitions)`
`void` TaosConsumer.`seekToEnd(Collection<TopicPartition> partitions)`

Constructor parameters in com.taosdata.jdbc.tmq with type arguments of type TopicPartition
Constructor and Description
`ConsumerRecords(Map<TopicPartition,List<ConsumerRecord<V>>> records)`
`OffsetWaitCallback(Map<TopicPartition,OffsetAndMetadata> offsets, JNIConsumer<?> consumer, OffsetCommitCallback<V> callback)`

### Uses of TopicPartition in com.taosdata.jdbc.ws.tmq

Methods in com.taosdata.jdbc.ws.tmq that return types with arguments of type TopicPartition
`Set<TopicPartition>` WSConsumer.`assignment()`
`Map<TopicPartition,Long>` WSConsumer.`beginningOffsets(String topic)`
`Map<TopicPartition,OffsetAndMetadata>` WSConsumer.`committed(Set<TopicPartition> partitions)`
`Map<TopicPartition,Long>` WSConsumer.`endOffsets(String topic)`
`Map<TopicPartition,Long>` WSConsumer.`position(String topic)`

Methods in com.taosdata.jdbc.ws.tmq with parameters of type TopicPartition
`OffsetAndMetadata` WSConsumer.`committed(TopicPartition partition)`
`long` WSConsumer.`position(TopicPartition partition)`
`void` WSConsumer.`seek(TopicPartition partition, long offset)`

Method parameters in com.taosdata.jdbc.ws.tmq with type arguments of type TopicPartition
`void` WSConsumer.`commitAsync(Map<TopicPartition,OffsetAndMetadata> offsets, OffsetCommitCallback<V> callback)`
`void` WSConsumer.`commitSync(Map<TopicPartition,OffsetAndMetadata> offsets)`
`Map<TopicPartition,OffsetAndMetadata>` WSConsumer.`committed(Set<TopicPartition> partitions)`
`void` WSConsumer.`seekToBeginning(Collection<TopicPartition> partitions)`
`void` WSConsumer.`seekToEnd(Collection<TopicPartition> partitions)`

### Uses of TopicPartition in com.taosdata.jdbc.ws.tmq.entity

Methods in com.taosdata.jdbc.ws.tmq.entity that return TopicPartition
`TopicPartition[]` CommittedReq.`getTopicPartitions()`
`TopicPartition[]` PositionReq.`getTopicPartitions()`

Methods in com.taosdata.jdbc.ws.tmq.entity with parameters of type TopicPartition
`Request` TMQRequestFactory.`generateCommitOffset(TopicPartition topicPartition, long offset)`
`Request` TMQRequestFactory.`generateCommitted(TopicPartition[] topicPartitions)`
`Request` TMQRequestFactory.`generatePosition(TopicPartition[] topicPartitions)`
`void` CommittedReq.`setTopicPartitions(TopicPartition[] topicPartitions)`
`void` PositionReq.`setTopicPartitions(TopicPartition[] topicPartitions)`