问题描述
在使用Apache Helix时,我注意到它以下列方式自动生成分区名称:ResourceName_0
,ResourceName_1
,... ResourceName_N
。将其来回转换为某些真实的现有资源名称(例如消息代理中的队列)有点尴尬。
我正在像这样从Java配置集群,这是rabbitmq-consumer-groups recipe的摘录。
ZkClient zkclient = new ZkClient(ZOOKEEPER_ADDRESS,ZkClient.DEFAULT_SESSION_TIMEOUT,ZkClient.DEFAULT_CONNECTION_TIMEOUT,new ZNRecordSerializer());
ZKHelixAdmin admin = new ZKHelixAdmin(zkclient);
// add cluster
admin.addCluster("ClusterName",true);
// add state model definition
admin.addStateModelDef("ClusterName",DEFAULT_STATE_MODEL,new StateModelDefinition(StateModelConfigGenerator.generateConfigForOnlineOffline()));
int partitions = 3;
admin.addResource("ClusterName","ResourceName",partitions,IdealState.RebalanceMode.FULL_AUTO.toString());
int replicas = 1;
admin.rebalance("ClusterName",replicas);
可以以某种方式自定义吗?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)