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) |
public ConsumerParam(Properties properties) throws SQLException
SQLExceptionpublic ConnectionParam getConnectionParam()
public void setConnectionParam(ConnectionParam connectionParam)
public String getGroupId()
public void setGroupId(String groupId)
public String getClientId()
public void setClientId(String clientId)
public String getOffsetRest()
public void setOffsetRest(String offsetRest)
public boolean isAutoCommit()
public String getAutoCommitInterval()
public void setAutoCommitInterval(String autoCommitInterval)
public String getMsgWithTableName()
public void setMsgWithTableName(String msgWithTableName)
public String getSnapshotEnable()
public void setSnapshotEnable(String snapshotEnable)
Copyright © 2023. All rights reserved.