提交 6a466402 编写于 作者: 张旭 提交者: affe

[ISSUE #2245]enhancement: expose config defaultBrokerId and...

[ISSUE #2245]enhancement: expose config defaultBrokerId and connectBrokerByUser for DefaultLitePullConsumer (#2246)
Co-authored-by: Nzhangxu16 <zhangxu16@xiaomi.com>
上级 9d34fadc
......@@ -307,6 +307,22 @@ public class DefaultLitePullConsumer extends ClientConfig implements LitePullCon
this.autoCommit = autoCommit;
}
public boolean isConnectBrokerByUser() {
return this.defaultLitePullConsumerImpl.getPullAPIWrapper().isConnectBrokerByUser();
}
public void setConnectBrokerByUser(boolean connectBrokerByUser) {
this.defaultLitePullConsumerImpl.getPullAPIWrapper().setConnectBrokerByUser(connectBrokerByUser);
}
public long getDefaultBrokerId() {
return this.defaultLitePullConsumerImpl.getPullAPIWrapper().getDefaultBrokerId();
}
public void setDefaultBrokerId(long defaultBrokerId) {
this.defaultLitePullConsumerImpl.getPullAPIWrapper().setDefaultBrokerId(defaultBrokerId);
}
public int getPullThreadNums() {
return pullThreadNums;
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册