com.taosdata.jdbc.tmq

## 接口 TConsumer<V>

所有超级接口:
  AutoCloseable

所有已知实现类:
  TaosConsumer

    public interface TConsumer<V>
    extends AutoCloseable

### 方法概要

所有方法 实例方法 抽象方法
`void` `close()`
`void` `commitAsync()`
`void` `commitAsync(OffsetCommitCallback callback)`
`void` `commitSync()`
`ConsumerRecords<V>` `poll(Duration timeout)`
`void` `subscribe(Collection<String> topics)`
`Set<String>` `subscription()`
`void` `unsubscribe()`

### 方法详细资料

#### subscribe

    void subscribe(Collection<String> topics)
            throws SQLException

抛出:
  `SQLException`

#### unsubscribe

    void unsubscribe()
              throws SQLException

抛出:
  `SQLException`

#### subscription

    Set<String> subscription()
                      throws SQLException

抛出:
  `SQLException`

#### poll

    ConsumerRecords<V> poll(Duration timeout)
                     throws SQLException

抛出:
  `SQLException`

#### commitAsync

    void commitAsync()

#### commitAsync

    void commitAsync(OffsetCommitCallback callback)

#### commitSync

    void commitSync()
             throws SQLException

抛出:
  `SQLException`

#### close

    void close()
        throws SQLException

指定者:
  `close` 在接口中 `AutoCloseable`
抛出:
  `SQLException`