com.taosdata.jdbc.tmq

## 类 TMQConnector

- java.lang.Object
- - com.taosdata.jdbc.TSDBJNIConnector
  - - com.taosdata.jdbc.tmq.TMQConnector

    public class TMQConnector
    extends TSDBJNIConnector

### 字段概要

### 从类继承的字段 com.taosdata.jdbc.TSDBJNIConnector

`taos`

### 构造器概要

构造器
构造器和说明
`TMQConnector()`

### 方法概要

所有方法 实例方法 具体方法
`void` `asyncCommit(long offset, OffsetWaitCallback<?> callback)`
`void` `closeConsumer()`
`long` `createConfig(Properties properties)`
`void` `createConsumer(long conf)`
`long` `createTopic(Collection<String> topics)`
`void` `destroyConf(long conf)`
`void` `destroyTopic(long topic)`
`int` `fetchBlock(long resultSet, TSDBResultSetBlockData blockData, List<ColumnMetaData> columnMetaData)`
`String` `getDbName(long res)`
`String` `getErrMsg(int code)`
`String` `getTableName(long res)`
`String` `getTopicName(long res)`
`int` `getVgroupId(long res)`
`long` `poll(long waitTime)`
`void` `setTopicList(String[] topics)`
`void` `subscribe(long topic)`
`Set<String>` `subscription()`
`void` `syncCommit(long offsets)`
`void` `unsubscribe()`

### 从类继承的方法 com.taosdata.jdbc.TSDBJNIConnector

`addBatch, bindColumnDataArray, closeBatch, closeConnection, connect, executeBatch, executeQuery, fetchBlock, fetchRow, freeResultSet, getAffectedRows, getErrCode, getErrMsg, getResultTimePrecision, getSchemaMetaData, getTableVGroupID, init, insertLines, isClosed, isResultsetClosed, isUpdateQuery, prepareStmt, setBindTableName, setBindTableNameAndTags`

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

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

### 构造器详细资料

#### TMQConnector

    public TMQConnector()

### 方法详细资料

#### createConfig

    public long createConfig(Properties properties)
                      throws SQLException

抛出:
  `SQLException`

#### destroyConf

    public void destroyConf(long conf)

#### createConsumer

    public void createConsumer(long conf)
                        throws SQLException

抛出:
  `SQLException`

#### createTopic

    public long createTopic(Collection<String> topics)
                     throws SQLException

抛出:
  `SQLException`

#### destroyTopic

    public void destroyTopic(long topic)

#### subscribe

    public void subscribe(long topic)
                   throws SQLException

抛出:
  `SQLException`

#### subscription

    public Set<String> subscription()
                             throws SQLException

抛出:
  `SQLException`

#### setTopicList

    public void setTopicList(String[] topics)

#### syncCommit

    public void syncCommit(long offsets)
                    throws SQLException

抛出:
  `SQLException`

#### asyncCommit

    public void asyncCommit(long offset,
                            OffsetWaitCallback<?> callback)

#### unsubscribe

    public void unsubscribe()
                     throws SQLException

抛出:
  `SQLException`

#### closeConsumer

    public void closeConsumer()
                       throws SQLException

抛出:
  `SQLException`

#### getErrMsg

    public String getErrMsg(int code)

#### poll

    public long poll(long waitTime)

#### getTopicName

    public String getTopicName(long res)

#### getDbName

    public String getDbName(long res)

#### getVgroupId

    public int getVgroupId(long res)

#### getTableName

    public String getTableName(long res)

#### fetchBlock

    public int fetchBlock(long resultSet,
                          TSDBResultSetBlockData blockData,
                          List<ColumnMetaData> columnMetaData)