com.taosdata.jdbc.ws.tmq.entity

## 类 ConsumerParam

- java.lang.Object
- - com.taosdata.jdbc.ws.tmq.entity.ConsumerParam

    public class ConsumerParam
    extends Object

### 构造器概要

构造器
构造器和说明
`ConsumerParam(Properties properties)`

### 方法概要

所有方法 实例方法 具体方法
`String` `getAutoCommitInterval()`
`String` `getClientId()`
`ConnectionParam` `getConnectionParam()`
`String` `getGroupId()`
`String` `getMsgWithTableName()`
`String` `getOffsetRest()`
`String` `getSnapshotEnable()`
`boolean` `isAutoCommit()`
`void` `setAutoCommitInterval(String autoCommitInterval)`
`void` `setClientId(String clientId)`
`void` `setConnectionParam(ConnectionParam connectionParam)`
`void` `setGroupId(String groupId)`
`void` `setMsgWithTableName(String msgWithTableName)`
`void` `setOffsetRest(String offsetRest)`
`void` `setSnapshotEnable(String snapshotEnable)`

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

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

### 构造器详细资料

#### ConsumerParam

    public ConsumerParam(Properties properties)
                  throws SQLException

抛出:
  `SQLException`

### 方法详细资料

#### getConnectionParam

    public ConnectionParam getConnectionParam()

#### setConnectionParam

    public void setConnectionParam(ConnectionParam connectionParam)

#### getGroupId

    public String getGroupId()

#### setGroupId

    public void setGroupId(String groupId)

#### getClientId

    public String getClientId()

#### setClientId

    public void setClientId(String clientId)

#### getOffsetRest

    public String getOffsetRest()

#### setOffsetRest

    public void setOffsetRest(String offsetRest)

#### isAutoCommit

    public boolean isAutoCommit()

#### getAutoCommitInterval

    public String getAutoCommitInterval()

#### setAutoCommitInterval

    public void setAutoCommitInterval(String autoCommitInterval)

#### getMsgWithTableName

    public String getMsgWithTableName()

#### setMsgWithTableName

    public void setMsgWithTableName(String msgWithTableName)

#### getSnapshotEnable

    public String getSnapshotEnable()

#### setSnapshotEnable

    public void setSnapshotEnable(String snapshotEnable)