public class DmsConsumeConfig
extends java.lang.Object
构造器和说明 |
---|
DmsConsumeConfig() |
限定符和类型 | 方法和说明 |
---|---|
java.util.List<java.lang.String> |
getAttrFilterList() |
java.lang.String |
getBroadcastGroup(java.lang.String group)
<一句话功能简述>
<功能详细描述>
|
java.lang.String |
getConsumeId() |
ConsumeMode |
getConsumeMode() |
int |
getDlReveives() |
int |
getLongPullTime() |
int |
getMaxBytes() |
int |
getMaxRecords() |
int |
getMsPullTime() |
int |
getMsWaitCommit() |
java.util.List<java.lang.String> |
getTagList() |
java.lang.String |
getTagType() |
boolean |
isAutoCommit() |
boolean |
isDlEnable() |
boolean |
isLongPoll() |
void |
setAttrFilterList(java.util.List<java.lang.String> attrFilterList) |
void |
setAutoCommit(boolean autoCommit) |
void |
setConsumeId(java.lang.String consumeId) |
void |
setConsumeMode(ConsumeMode consumeMode) |
void |
setDlEnable(boolean dlEnable) |
void |
setDlReveives(int dlReveives) |
void |
setLongPoll(boolean longPoll) |
void |
setLongPullTime(int longPullTime)
setLongPullTime
|
void |
setMaxBytes(int maxBytes) |
void |
setMaxRecords(int maxRecords) |
void |
setMsPullTime(int msPullTime) |
void |
setMsWaitCommit(int msWaitCommit) |
void |
setTagList(java.util.List<java.lang.String> tagList) |
void |
setTagType(java.lang.String tagType) |
public int getLongPullTime()
public void setLongPullTime(int longPullTime)
longPullTime
- longPullTimepublic boolean isLongPoll()
public void setLongPoll(boolean longPoll)
public int getMaxRecords()
public void setMaxRecords(int maxRecords)
public int getMsPullTime()
public void setMsPullTime(int msPullTime)
public int getMaxBytes()
public void setMaxBytes(int maxBytes)
public int getMsWaitCommit()
public void setMsWaitCommit(int msWaitCommit)
public java.util.List<java.lang.String> getAttrFilterList()
public void setAttrFilterList(java.util.List<java.lang.String> attrFilterList)
public java.util.List<java.lang.String> getTagList()
public void setTagList(java.util.List<java.lang.String> tagList)
public java.lang.String getTagType()
public void setTagType(java.lang.String tagType)
public boolean isDlEnable()
public void setDlEnable(boolean dlEnable)
public int getDlReveives()
public void setDlReveives(int dlReveives)
public java.lang.String getConsumeId()
public void setConsumeId(java.lang.String consumeId)
public ConsumeMode getConsumeMode()
public void setConsumeMode(ConsumeMode consumeMode)
public java.lang.String getBroadcastGroup(java.lang.String group)
group
- grouppublic boolean isAutoCommit()
public void setAutoCommit(boolean autoCommit)