public class ConsumerParam extends Object
| 构造器和说明 |
|---|
ConsumerParam(Properties properties) |
| 限定符和类型 | 方法和说明 |
|---|---|
String |
getClientId() |
ConnectionParam |
getConnectionParam() |
String |
getGroupId() |
String |
getOffsetRest() |
boolean |
isAutoCommit() |
void |
setClientId(String clientId) |
void |
setConnectionParam(ConnectionParam connectionParam) |
void |
setGroupId(String groupId) |
void |
setOffsetRest(String offsetRest) |
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()
Copyright © 2023. All rights reserved.