微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

使用Apache Helix时可以自定义分区名称吗?

如何解决使用Apache Helix时可以自定义分区名称吗?

在使用Apache Helix时,我注意到它以下列方式自动生成分区名称ResourceName_0ResourceName_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 举报,一经查实,本站将立刻删除。