public class SubscribeReq extends Payload
| 构造器和说明 |
|---|
SubscribeReq() |
| 限定符和类型 | 方法和说明 |
|---|---|
String |
getAutoCommit() |
String |
getAutoCommitIntervalMs() |
String |
getClientId() |
String |
getDb() |
String |
getGroupId() |
String |
getOffsetRest() |
String |
getPassword() |
String |
getSnapshotEnable() |
String[] |
getTopics() |
String |
getUser() |
String |
getWithTableName() |
void |
setAutoCommit(String autoCommit) |
void |
setAutoCommitIntervalMs(String autoCommitIntervalMs) |
void |
setClientId(String clientId) |
void |
setDb(String db) |
void |
setGroupId(String groupId) |
void |
setOffsetRest(String offsetRest) |
void |
setPassword(String password) |
void |
setSnapshotEnable(String snapshotEnable) |
void |
setTopics(String[] topics) |
void |
setUser(String user) |
void |
setWithTableName(String withTableName) |
public String getUser()
public void setUser(String user)
public String getPassword()
public void setPassword(String password)
public String getDb()
public void setDb(String db)
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 String[] getTopics()
public void setTopics(String[] topics)
public String getAutoCommit()
public void setAutoCommit(String autoCommit)
public String getAutoCommitIntervalMs()
public void setAutoCommitIntervalMs(String autoCommitIntervalMs)
public String getSnapshotEnable()
public void setSnapshotEnable(String snapshotEnable)
public String getWithTableName()
public void setWithTableName(String withTableName)
Copyright © 2023. All rights reserved.