程序包 com.taosdata.jdbc.tmq

## 类 TaosConsumer<V>

- java.lang.Object
- - com.taosdata.jdbc.tmq.TaosConsumer<V>

所有已实现的接口:
  `TConsumer<V>`, `AutoCloseable`

    public class TaosConsumer<V>
    extends Object
    implements TConsumer<V>

### 构造器概要

构造器
`TaosConsumer​(Properties properties)` Note: after creating a `TaosConsumer` you must always `close()` it to avoid resource leaks.

### 方法概要

所有方法 实例方法 具体方法
`void` `close()`
`void` `commitAsync()`
`void` `commitAsync​(OffsetCommitCallback callback)`
`void` `commitCallbackHandler​(int code)`
`void` `commitSync()`
`ConsumerRecords<V>` `poll​(Duration timeout)`
`void` `subscribe​(Collection<String> topics)`
`Set<String>` `subscription()`
`void` `unsubscribe()`

### 从类继承的方法 java.lang.Object

`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

### 构造器详细资料

#### TaosConsumer

    public TaosConsumer​(Properties properties)
                 throws SQLException

Note: after creating a `TaosConsumer` you must always `close()` it to avoid resource leaks.

抛出:
  `SQLException`

### 方法详细资料

#### commitCallbackHandler

    public void commitCallbackHandler​(int code)

#### subscribe

    public void subscribe​(Collection<String> topics)
                   throws SQLException

指定者:
  `subscribe` 在接口中 `TConsumer<V>`
抛出:
  `SQLException`

#### unsubscribe

    public void unsubscribe()
                     throws SQLException

指定者:
  `unsubscribe` 在接口中 `TConsumer<V>`
抛出:
  `SQLException`

#### subscription

    public Set<String> subscription()
                             throws SQLException

指定者:
  `subscription` 在接口中 `TConsumer<V>`
抛出:
  `SQLException`

#### poll

    public ConsumerRecords<V> poll​(Duration timeout)
                            throws SQLException

指定者:
  `poll` 在接口中 `TConsumer<V>`
抛出:
  `SQLException`

#### commitAsync

    public void commitAsync()

指定者:
  `commitAsync` 在接口中 `TConsumer<V>`

#### commitAsync

    public void commitAsync​(OffsetCommitCallback callback)

指定者:
  `commitAsync` 在接口中 `TConsumer<V>`

#### commitSync

    public void commitSync()
                    throws SQLException

指定者:
  `commitSync` 在接口中 `TConsumer<V>`
抛出:
  `SQLException`

#### close

    public void close()
               throws SQLException

指定者:
  `close` 在接口中 `AutoCloseable`
指定者:
  `close` 在接口中 `TConsumer<V>`
抛出:
  `SQLException`